• 主页
• 运维
• 开发
• 公告
• 登录
• 注册

1、查看消费组

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

2、查看消费组消费的情况

./kafka-consumer-groups.sh --bootstrap-server 172.18.192.107:9092 --describe --group zjz

查看topic

2.2.x

./kafka-topics.sh

--zookeeper 192.168.15.6:2181

--list

2.13.x

./kafka-topics.sh --bootstrap-server 10.246.101.186:9002 --list

创建topic

./kafka-topics.sh               

 --zookeeper 192.168.15.6:2181  

 --create                     

 --replication-factor 3          

 --partitions 3                 

 --topic first

创建一个名为first的topic

--zookeeper：指定zookeeper的地址

--create：创建

--replication-factor：创建几个副本

--partitions：创建几个分区

--topic：主题名

 

删除topic

首先需要server.properties中设置delete.topic.enable=true，重启

2.2.x

./kafka-topics.sh

--zookeeper 192.168.15.6:2181

--delete

--topic second

2.13.x

./kafka-topics.sh --bootstrap-server 10.246.101.186:9002 --delete --topic dispatcher_data_t5

 

查看topic的详情

./kafka-topics.sh                

--zookeeper 192.168.15.6:2181          

--describe                   

--topic second

 

创建消费者

./kafka-console-producer.sh

--broker-list localhost:9092

--topic first

 

创建生产者

./kafka-console-consumer.sh      

--bootstrap-server localhost:9092  

--topic first