kafkacat

kafkacat

TLDR

Consume messages starting with the newest offset

$ kafkacat -C -t [topic] -b [brokers]
copy


Consume messages starting with the oldest offset and exit after the last message is received
$ kafkacat -C -t [topic] -b [brokers] -o beginning -e
copy


Consume messages as a Kafka consumer group
$ kafkacat -G [group_id] [topic] -b [brokers]
copy


Publish message by reading from stdin
$ echo [message] | kafkacat -P -t [topic] -b [brokers]
copy


Publish messages by reading from a file
$ kafkacat -P -t [topic] -b [brokers] [path/to/file]
copy


List metadata for all topics and brokers
$ kafkacat -L -b [brokers]
copy


List metadata for a specific topic
$ kafkacat -L -t [topic] -b [brokers]
copy


Get offset for a topic/partition for a specific point in time
$ kafkacat -Q -t [topic]:[partition]:[unix_timestamp] -b [brokers]
copy

Copied to clipboard