停止 ./bin/kafka-server-stop.sh? 啟動 nohup sh kafka-server-start.sh ../config/server.properties & 創建topic ，并指定partion sh kafka-topics.sh --create --zookeeper?192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08?--replication-factor 3 --partitions 9 --topic?DS.crawl_news_download_queue_v2_6 查看kafka ?一個groupid 消費的偏移量 sh kafka-run-class.sh?kafka.tools.ConsumerOffsetChecker?--zookeeper192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08?--group?parse_group 跟讀 sh kafka-console-consumer.sh?--zookeeper?192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08?--topic??DS.crawl.output.mf.self 查看某個topic的partion情況 sh?kafka-topics.sh??--describe?--zookeeper?192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08?--topic?DS.crawl.output.mf.self 增加topic的partition ./kafka-topics.sh --alter?--topic topic1?--zookeeper zkip:2181/kafka --partitions 6 ? 刪除topic sh?kafka-topics.sh??--delete??--zookeeper?192.168.67.74:2182,192.168.67.68:2182,192.168.67.73:2182/kafka08?--topic?DS.crawl_parseToTopic_v2_metasearch 寫 sh?kafka-console-producer.sh?--broker-list?192.168.67.35:8791,192.168.67.36:8791,192.168.67.37:8791?--topic?test、 跟讀 sh?kafka-console-consumer.sh?--zookeeper?192.168.67.35:2182,192.168.67.36:2182,192.168.67.37:2182/kafka08

轉載于:https://www.cnblogs.com/amei0/p/9088223.html

總結

以上是生活随笔為你收集整理的kafka shell的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。