kafkadog

README

kafkadog

A Kafka consumer/producer CLI. Barking version of Kafkacat.

Example usage

Consumer

Read messages and print their value on stdout :

$ kafkadog consume -b mybroker:9092 my_topic

Read messages and print them with the format topic.partition.offset -> value on stdout :

$ kafkadog consume -b mybroker:9092 -f '%t.%p.%o -> %v' my_topic

Read messages starting at the oldest available offset and print their value on stdout :

$ kafkadog consume -b mybroker:9092 my_topic

Producer

Produce one message :

$ echo '{"msg": "hello"}' | kafkadog produce -b mybroker:9092 my_topic

Produce messages read from stdin (default is one message per line, close with Ctrl-D / Ctrl-C) :

$ kafkadog produce -b mybroker:9092 my_topic

Produce messages read from a file (default is one message per line) :

$ kafkadog produce -b mybroker:9092 -f messages.txt my_topic

Detailed usage

Run kafkadog -h for detailed usage and help.

Credits

• Shopify/sarama
• spf13/cobra