1.kafka維護的一些命令：

1.1建立topic

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

1.2查詢所有topic

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

1.3檢視topic描述資訊

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

1.4刪除kafka的topic

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

1.5模擬生產者寫入資料到topic中

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

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.7檢視某一消費組下的offset資訊

檢視消費者組列表

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

檢視某一消費者組的描述資訊

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

你的點贊與評論是我最大的創作動力！