kafka命令行工具

Plain text
Copy to clipboard
Open code in new window
EnlighterJS 3 Syntax Highlighter
# add topic
kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --create --partitions 1 --topic topic1 --replication-factor 1
Created topic "topic1".
# list topic
kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --list
# describe topic
kafka-topics.sh --describe --zookeeper sbmvt-zk-test:2181 --topic topic1
# publish topic
kafka-console-producer.sh --broker-list kafka_kafka-1-test:9092 --topic topic1
# consume topic
kafka-console-consumer.sh --zookeeper sbmvt-zk-test:2181 --from-beginning --topic topic1
# add topic kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --create --partitions 1 --topic topic1 --replication-factor 1 Created topic "topic1". # list topic kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --list # describe topic kafka-topics.sh --describe --zookeeper sbmvt-zk-test:2181 --topic topic1 # publish topic kafka-console-producer.sh --broker-list kafka_kafka-1-test:9092 --topic topic1 # consume topic kafka-console-consumer.sh --zookeeper sbmvt-zk-test:2181 --from-beginning --topic topic1
# add topic
kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --create --partitions 1 --topic topic1 --replication-factor 1
Created topic "topic1".

# list topic
kafka-topics.sh --zookeeper sbmvt-zk-test:2181 --list

# describe topic
kafka-topics.sh --describe --zookeeper sbmvt-zk-test:2181 --topic topic1

# publish topic
kafka-console-producer.sh --broker-list kafka_kafka-1-test:9092 --topic topic1

# consume topic
kafka-console-consumer.sh --zookeeper sbmvt-zk-test:2181 --from-beginning --topic topic1

 

Leave a Reply

Your email address will not be published. Required fields are marked *