1、啟動kafka

nohup ./kafka-server-start.sh ../config/server.properties &&>/dev/null 2>&1 &

或者不指定日志輸出位置和設置

./kafka-server-start.sh ../config/server.properties &

2、查看所有topic

./kafka-topics.sh --zookeeper 172.18.111.106:2181 --list

3、刪除topic

./kafka-topics.sh --delete --zookeeper 172.18.111.106:2181 --topic audit_db_audit_data_topic

4、查看某一分組消費情況

./kafka-consumer-groups.sh --bootstrap-server 172.18.111.106:9092 --describe --group kafka_result_id

5、所有分組消費情況

./kafka-consumer-groups.sh --bootstrap-server 172.18.111.106:9092 --describe --all-groups

6、消費某一topic

./kafka-console-consumer.sh --bootstrap-server 172.18.111.106:9092 --topic task_result_topic --from-beginning

7、啟動生產客戶端

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic kfcs

8、查看某一topic的消費情況

./kafka-topics.sh?--bootstrap-server 172.18.111.106:9092??--describe --topic xxxx

9、創建topic

./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --partitions 1 --replication-factor 1

總結

以上是生活随笔為你收集整理的linux开启kafka消费者命令,Linux kafka常用命令的全部內容，希望文章能夠幫你解決所遇到的問題。

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