Skip to content

Kafka debugging

Nikita Marchenko edited this page Apr 9, 2018 · 8 revisions

Consuming messages from topic:

`docker exec -ti kafka /opt/kafka/bin/kafka-console-consumer.sh --topic=<TOPIC_NAME> --bootstrap-server=kafka.pendev:9092

List of groups

docker exec -ti kafka /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server=kafka.pendev:9092 --list

Stats of consumer

docker exec -ti kafka /opt/kafka/bin/kafka-consumer-groups.sh --bootstrap-server=kafka.pendev:9092 --describe --group <GROUP_ID_FROM_LIST_COMMAND>

Clone this wiki locally