创建topic验证kafka集群

0)‘‘‘kafka&zookpeer信息‘‘‘

zkinfo:

172.18.238.2:2181

172.18.238.3:2181

172.18.238.4:2181

kafkainfo:

172.18.238.2:9092

172.18.238.3:9092

172.18.238.4:9092

1)‘‘‘创建Topic(包含10个分区，2个副本)‘‘‘

sh bin/kafka-topics.sh --create --zookeeper 172.18.238.2:2181 --replication-factor 2 --partitions 10 --topic xiaoke

#解释

--replication-factor 2   #复制两份

--partitions 10 #创建10个分区

--topic #主题为xiaoke

2)‘‘‘查看有哪些主题‘‘‘

sh bin/kafka-topics.sh --list --zookeeper 172.18.238.2:2181

3)‘‘‘查看主题的具体信息‘‘‘

sh bin/kafka-topics.sh --describe --zookeeper 172.18.238.2:2181  --topic xiaoke

4)‘‘‘在一台服务器上创建一个发布者‘‘‘

#创建一个broker，发布者

sh bin/kafka-console-producer.sh --broker-list 172.18.238.2:9092 --topic xiaoke

#解释

--broker-list 172.18.238.2:9092 kafka的地址

5）‘‘‘在另一台服务器上创建一个订阅者‘‘‘

sh bin/kafka-console-consumer.sh --zookeeper 172.18.238.2:2181  --topic xiaoke --from-beginning

6）‘‘‘查看kafka集群有哪些消费组‘‘‘

sh bin/kafka-consumer-groups.sh --bootstrap-server 172.18.238.2:9092 --list

#解释

--bootstrap-server 172.18.238.2:9092 kafka的地址

7）‘‘‘查看具体消费者信息‘‘‘

sh kafka-consumer-groups.sh  --bootstrap-server 172.18.238.2:9092 --describe --group GROUPNAME