cd kafka/bin
然后執(zhí)行
（老版本是指定zk的地址拦惋，類似這樣：kafka-consumer-groups.sh --zookeeper 127.0.0.1:2181 --list? ? 新版本使用bootstrap，這個是區(qū)別杆融。）
查看所有主題
./kafka-topics.sh --zookeeper localhost:2181 --list
查看主題詳細(xì)情況抹镊，如分區(qū)個數(shù)等
./kafka-topics.sh --zookeeper 192.168.0.248:2181 192.168.0.249:2181 192.168.0.250:2181 --topic EntInfo_json --describe
查看所有消費者
./kafka-consumer-groups.sh --bootstrap-server 192.168.1.171:9092 --list
查看指定消費者消費情況
./kafka-consumer-groups.sh --bootstrap-server 192.168.0.248:9092 192.168.0.249:9092 192.168.0.250:9092 --group data-consumer --describe
查詢匹配指定內(nèi)容的消息
./kafka-console-consumer.sh --bootstrap-server 192.168.0.248:9092,192.168.0.249:9092,192.168.0.250:9092 --topic EntInfo_json --from-beginning | grep "SUPERCARE236TEST"
有可能查不出來
修改kafka指定消費者偏移量
--to-datetime后面跟的的UTC時間亿扁，需要減8小時如蚜。例如下面實際上表示北京時間為2022-06-14T18:00:00.000。
--group后跟消費者名稱挡逼。--execute --topic 跟主題名稱括改，全部主題則為--all-topics
注意：修改偏移量要停止消費者服務(wù)。
./kafka-consumer-groups.sh --bootstrap-server 10.109.3.127:9092 --group case-consumer --reset-offsets --to-datetime 2022-06-14T10:00:00.000 --execute --topic Eimp.CIDC.GenAlarmDiagnosticReport
修改所有主題kafka偏移量到最早
./kafka-consumer-groups.sh --bootstrap-server 10.109.3.127:9092 --group case-consumer --reset-offsets --all-topics --to-earliest --execute
修改單個主題的kafka偏移量到最早
./kafka-consumer-groups.sh --bootstrap-server 192.168.1.149:9092 --group data-consumer --reset-offsets? --to-earliest --execute --topic?Eimp.TraitData
修改單個主題的kafka偏移量到指定
./kafka-consumer-groups.sh --bootstrap-server 192.168.1.149:9092 --group data-consumer --reset-offsets --to-offset 500000 --execute --topic Eimp.TraitData
修改單個主題的kafka偏移量到當(dāng)前最新
./kafka-consumer-groups.sh --bootstrap-server 192.168.1.149:9092 --group data-consumer --reset-offsets --to-current --execute --topic Eimp.TraitData
創(chuàng)建主題
?./kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 2 --topic spring-kafka-demo2
刪除主題
Kafka服務(wù)開啟delete.topic.enable=true。開啟后需要重啟Kafka服務(wù)嘱能。
./kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic test
