Ejecución manual

La sintaxis de ejecución es la siguiente:

./pandora_kafka \
  --bootstrap_servers <host:port[,host:port,...]> \
  [--topics <topic1,topic2,...>] \
  [--topic_regex <regex>] \
  [--agent_prefix <prefix>] \
  [--module_prefix <prefix>] \
  [--transfer_mode <mode>] \
  [--tentacle_ip <ip>] \
  [--tentacle_port <port>] \
  [--verbose]

Ejemplo utilizando una expresión regular para seleccionar topics:

./pandora_kafka \
  --bootstrap_servers kafka1:9092,kafka2:9092 \
  --topic_regex '^prod-.*' \
  --agent_prefix 'KAFKA_' \
  --module_prefix '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.