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}}