Skip to content

Instantly share code, notes, and snippets.

@pavankjadda

pavankjadda/KafkaCommands.md

Last active February 1, 2019 01:12
Show Gist options
  • Save pavankjadda/64840f97abd86d28c0518a7750cd5e85 to your computer and use it in GitHub Desktop.
Save pavankjadda/64840f97abd86d28c0518a7750cd5e85 to your computer and use it in GitHub Desktop.
Download ZIP
Kafka Commands
Raw
KafkaCommands.md

Kafka Topic Commands

bin/kafka-topics.sh --list --zookeeper 172.19.0.8:2181

bin/kafka-topics.sh --describe --zookeeper 172.19.0.8:2181 --topic customChannel

bin/kafka-topics.sh --zookeeper 172.19.0.8:2181 --delete --topic customChannel

bin/kafka-topics.sh --create --zookeeper 172.19.0.8:2181 --replication-factor 1 --partitions 1 --topic greetings



bin/kafka-console-producer.sh --broker-list 172.19.0.4:9092 --topic subscribableChannel

bin/kafka-console-consumer.sh --bootstrap-server 172.19.0.4:9092 --topic customChannel --from-beginning

Kafka application reset command

<path-to-confluent>/bin/kafka-streams-application-reset --application-id=<application name>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment