1、查看當(dāng)前服務(wù)器中的所有topic
[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --list
2、創(chuàng)建topic
[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --create \
--replication-factor 4 --partitions 5 --topic first
選項說明
--topic 定義topic名
--replication-factor 定義副本數(shù)
--partitions 定義分區(qū)數(shù)
3、刪除topic
[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --delete \
--topic first
尖叫提示：需要server.properties中設(shè)置delete.topic.enable=true否則只是標記刪除或者直接重啟。
4、發(fā)送消息 (生產(chǎn)者)
[victor@node1 kafka]$ bin/kafka-console-producer.sh --broker-list node1:9092 \
--topic first
> hello world
> datou datou
5、消費消息(消費者)
[victor@node2 kafka]$ bin/kafka-console-consumer.sh --zookeeper node1:2181 \
--from-beginning --topic first
尖叫提示：--from-beginning：會把first主題中以往所有的數(shù)據(jù)都讀取出來。根據(jù)業(yè)務(wù)場景選擇是否增加該配置。
6、查看某個Topic的詳情
[victor@node1 kafka]$ bin/kafka-topics.sh --zookeeper node1:2181 --describe \
--topic first
Topic:first PartitionCount:4 ReplicationFactor:3 Configs:
Topic: first Partition: 0 Leader: 0 Replicas: 0,1,2 Isr: 0,1,2
Topic: first Partition: 1 Leader: 1 Replicas: 1,2,0 Isr: 1,2,0
Topic: first Partition: 2 Leader: 2 Replicas: 2,0,1 Isr: 2,0,1
Topic: first Partition: 3 Leader: 0 Replicas: 0,2,1 Isr: 0,2,1
