LinuxCommandLibrary

kcat

Apache Kafka producer and consumer tool.

TLDR

Consume messages starting with the newest offset

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


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


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


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


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


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


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


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

Copied to clipboard