Kafka debugging

Topic list:

docker exec -ti kafka /opt/kafka/bin/kafka-topics.sh --zookeeper zookeeper.kilda:2181 --list

Consuming messages from topic:

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

List of groups

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

Stats of consumer

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

Send message to topic:

docker exec -ti kafka /opt/kafka/bin/kafka-console-producer.sh --broker-list=kafka.kilda:9092 --topic=<TOPIC_NAME>