kafka常用维护查看shell命令（创建topic、查看、删除、生产者、消费者、消费者组offset）

1.kafka维护的一些命令：

1.1创建topic

kafka-topics.sh --create --partitions 1 --replication-factor 2 --topic test --zookeeper companynode02:2181,companynode03:2181,companynode04:2181

  

 

  
1
 

1.2查询所有topic

kafka-topics.sh --list --zookeeper companynode02:2181,companynode03:2181,companynode04:2181 

  

 

  
1
 

1.3查看topic描述信息

kafka-topics.sh --describe --topic test --zookeeper companynode02:2181,companynode03:2181,companynode04:2181  

  

 

  
1
 

1.4删除kafka的topic

kafka-topics.sh --delete --topic test --zookeeper companynode02:2181,companynode03:2181,companynode04:2181 

  

 

  
1
 

1.5模拟生产者写入数据到topic中

kafka-console-producer.sh --broker-list companynode02:9092,companynode03:9092,companynode04:9092 --topic test 

  

 

  
1
 

1.6模拟消费者拉取topic中的数据

kafka-console-consumer.sh --zookeeper companynode02:2181,companynode03:2181,companynode04:2181 --topic test --from-beginning

或者

kafka-console-consumer.sh --bootstrap-server companynode02:9092,companynode03:9092,companynode04:9092 --topic test --from-beginning

  

 

  
1
  
2
  
3
  
4
  
5
 

1.7查看某一消费组下的offset信息

查看消费者组列表

kafka-consumer-groups.sh --new-consumer --bootstrap-server companynode01:9092,companynode02:9092,companynode03:9092  --list

  

 

  
1
 

查看某一消费者组的描述信息

kafka-consumer-groups.sh --bootstrap-server companynode01:9092,companynode02:9092,companynode03:9092 --describe --group crawlgroup

  

 

  
1
 

你的点赞与评论是我最大的创作动力！

文章来源: blog.csdn.net，作者：橙子园，版权归原作者所有，如需转载，请联系作者。

原文链接：blog.csdn.net/Chenftli/article/details/114399492