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

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

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