tldr/pages/common/kcat.md

936 B

kcat

Apache Kafka producer and consumer tool. More information: https://github.com/edenhill/kcat.

  • Consume messages starting with the newest offset:

kcat -C -t {{topic}} -b {{brokers}}

  • Consume messages starting with the oldest offset and exit after the last message is received:

kcat -C -t {{topic}} -b {{brokers}} -o beginning -e

  • Consume messages as a Kafka consumer group:

kcat -G {{group_id}} {{topic}} -b {{brokers}}

  • Publish message by reading from stdin:

echo {{message}} | kcat -P -t {{topic}} -b {{brokers}}

  • Publish messages by reading from a file:

kcat -P -t {{topic}} -b {{brokers}} {{path/to/file}}

  • List metadata for all topics and brokers:

kcat -L -b {{brokers}}

  • List metadata for a specific topic:

kcat -L -t {{topic}} -b {{brokers}}

  • Get offset for a topic/partition for a specific point in time:

kcat -Q -t {{topic}}:{{partition}}:{{unix_timestamp}} -b {{brokers}}