Console based consumer for dockerized kafka Console based consumer for dockerized kafka docker docker

Console based consumer for dockerized kafka


Kafka Cheatsheet FYR,

Console Producer & Consumer

kafka-console-consumer --zookeeper localhost:2181/kafka --topic  topic_name --from-beginningkafka-console-producer --broker-list localhost:9092 --topic topic_namekafka-topics --zookeeper localhost:2181/kafka --list

Topic details & Deleting topic

kafka-topics --describe --zookeeper localhost:2181/kafka --topic topic_namekafka-configs --zookeeper localhost:2181/kafka --alter --entity-type topics --entity-name topic_name --add-config retention.ms=1000kafka-topics --delete --zookeeper localhost:2181/kafka --topic topic_name

Check active brokers

zookeeper-shell localhost:2181/kafka ls /brokers/ids

KafkaCat

kafkacat -b localhost:9092 -L | grep topickafkacat -C -b localhost:9092 -o -5 -t topic_name