1、建立 topic：
[root@node1 bin]# ./kafka-topics.sh --zookeeper node2:2181,node3:2181,node3:2181 --create --topic topic1 --partitions 3 --replication-factor 3
Created topic "topic1". 2、用一台節點控制台來當 kafka 的生産者：
[root@node1 bin]# ./kafka-console-producer.sh --topic topic1 --broker-list node1:9092,node2:9092,node3:9092 
3、用另一台節點控制台來當 kafka 的消費者：
[root@node2 bin]# ./kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic topic1 
4、檢視topic分組
[root@node1 bin]# ./kafka-topics.sh --zookeeper node2:2181,node3:2181,node3:2181 --list
topic1 [root@node3 bin]# ./kafka-consumer-groups.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --list
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).
console-consumer-71901 [root@node3 bin]# ./kafka-consumer-groups.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --describe --group console-consumer-71901
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).
TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
topic1 0 2 2 0 consumer-1-24253251-9c16-48f5-b0a0-8a8abf642f78 /192.168.134.102 consumer-1
topic1 1 2 2 0 consumer-1-24253251-9c16-48f5-b0a0-8a8abf642f78 /192.168.134.102 consumer-1
topic1 2 2 2 0 consumer-1-24253251-9c16-48f5-b0a0-8a8abf642f78 /192.168.134.102 consumer-1