创建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
页:
[1]