创建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

本文出自 “小科” 博客，请务必保留此出处http://kexiaoke.blog.51cto.com/5530023/1961980

创建topic验证kafka集群

原文：http://kexiaoke.blog.51cto.com/5530023/1961980