kcat
Apache Kafka producer and consumer tool. tldr-pages
On several platforms
Several platforms
Consume messages starting with the newest offset
kcat -C -t topic -b brokersIdentifyConsume messages starting with the oldest offset and exit after the last message is received
kcat -C -t topic -b brokers -o beginning -eIdentifyConsume messages as a Kafka consumer group
kcat -G group_id topic -b brokersIdentifyPublish message by reading from stdin
echo message | kcat -P -t topic -b brokersIdentifyPublish messages by reading from a file
kcat -P -t topic -b brokers path/to/fileIdentifyList metadata for all topics and brokers
kcat -L -b brokersIdentifyList metadata for a specific topic
kcat -L -t topic -b brokersIdentifyGet offset for a topic/partition for a specific point in time
kcat -Q -t topic:partition:unix_timestamp -b brokersIdentify