Skip to content

Instantly share code, notes, and snippets.

@swallentin

swallentin/kafka-local-create-topic.sh

Last active September 22, 2015 13:20
Show Gist options
  • Save swallentin/8a03beabe0b3f76a3375 to your computer and use it in GitHub Desktop.
Save swallentin/8a03beabe0b3f76a3375 to your computer and use it in GitHub Desktop.
Download ZIP
KAFKA Management Snippers
Raw
kafka-local-create-topic.sh
kafka-topics.sh --create --topic mytopic --zookeeper localhost:2181 --partitions 1 --replication-factor 1
Raw
kafka-prod-alter-topic-partitions
./kafka-topics.sh --zookeeper 172.31.44.217:2181 --alter --topic testforspark --partitions 3
Raw
kafka-prod-console-consumer-from-beginning
/kafka-console-consumer.sh --zookeeper 172.31.44.217:2181 --topic testforspark --from-beginning
Raw
kafka-prod-console-producer.sh
./kafka-console-producer.sh --broker-list 172.31.35.211:9092,172.31.41.6:9092,172.31.38.135:9092 --topic testforspark
Raw
zookeeper-kafka-local-start-server.sh
zookeeper-server-start.sh $KAFKA_HOME/config/zookeeper.properties
kafka-server-start.sh $KAFKA_HOME/config/server.properties
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment