Ejecución manual

La sintaxis de ejecución es la siguiente:

./pandora_kafka \
  --bootstrap_servers <ip:host:port[,ip:host:port,...]> \
  [ --topics <topic1,topic2,...> ] \
  [ --topic_regex <regex_patternregex> ] \
  [ --agent_prefix <prefix> ] \
  [ --module_prefix <prefix> ] \
  [ --transfer_mode <tentacle|localmode> ] \
  [ --tentacle_ip <ip> ] \
  [ --tentacle_port <port> ] \
  [ --verboseverbose]
]

Ejemplo

Porutilizando ejemplouna :expresión regular para seleccionar topics:

./pandora_kafka \
  --bootstrap_servers kafka1:9092,kafka2:9092 \
  --topic_regex "'^prod-.*"' \
  --agent_prefix KAFKA_'KAFKA_' \
  --module_prefix METRIC_'METRIC_' \
  --transfer_mode tentacle \
  --tentacle_ip 10.0.0.20 \
  --tentacle_port 41121 \
  --verbose

También se puede seleccionar una lista concreta de topics:

./pandora_kafka \
  --bootstrap_servers kafka1:9092 \
  --topics orders,payments

Si se indican a la vez --topics y --topic_regex, el plugin utiliza --topic_regex.

Al finalizar, el plugin imprime 1 si no se ha producido ningún error durante el procesamiento de los brokers y 0 si alguno de ellos ha provocado una excepción. Con --verbose se muestra el detalle de los errores detectados.