目录

列出所有topic

创建topic

删除topic

查询topic的描述信息

模拟生产者

模拟消费者

---

列出所有topic

# 通过 zk 集群中的一个列出所有 topic
bin/kafka-topics.sh --list --zookeeper 10.10.2.60:2181

 

 

创建topic

# 注意创建的分区数是可以大于brokers的个数，但是创建的副本数只能 <= brokers的个数 
bin/kafka-topics.sh --create --zookeeper 10.10.2.60:2181 --topic suntest --partitions 2 --replication-factor 2

 

 

删除topic

# 如果server.properties中设置的delete.topic.enable为true，则直接删除，如果为false，只是标记为删除 
bin/kafka-topics.sh --delete --zookeeper 10.10.2.60:2181 --topic suntest

 

 

查询topic的描述信息

bin/kafka-topics.sh --describe --topic suntest --zookeeper 10.10.2.60:2181

 

 

模拟生产者

bin/kafka-console-producer.sh --brokerlist hadoop102:9092 --topic suntest 
>

 

 

模拟消费者

// 老 
bin/kafka-console-consumer.sh --topic suntest --zookeeper 10.10.2.60:2181 
// 新 
bin/kafka-console-consumer.sh --topic suntest --bootstrap-server 10.10.2.81:9092 
bin/kafka-console-consumer.sh --topic suntest --bootstrap-server 10.10.2.81:9092 --from beginning