建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
簡單介紹一下kafka常用命令
Kafka是一個分布式、分區(qū)的、多副本的、多訂閱者，基于zookeeper協(xié)調(diào)的分布式日志系統(tǒng)（也可以當(dāng)做MQ系統(tǒng)），常見可以用于web/nginx日志、訪問日志，消息服務(wù)等等，本篇文章重點為大家講解一下kafka常用命令。
為白沙黎族等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及白沙黎族網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為做網(wǎng)站、成都網(wǎng)站設(shè)計、白沙黎族網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！
1、啟動kafka服務(wù)
bin/kafka-server-start.sh config/server.properties &
2、停止kafka服務(wù)
./kafka-server-stop.sh
3、查看所有的話題
./kafka-topics.sh --list --zookeeper localhost:9092
4、查看所有話題的詳細信息
./kafka-topics.sh --zookeeper localhost:2181 --describe
5、列出指定話題的詳細信息
./kafka-topics.sh --zookeeper localhost:2181 --describe --topic demo
6、刪除一個話題
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
7、創(chuàng)建一個叫test的話題，有兩個分區(qū)，每個分區(qū)3個副本
./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 3 --partitions 2
8、測試kafka發(fā)送和接收消息（啟動兩個終端）
#發(fā)送消息（注意端口號為配置文件里面的端口號）
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
#消費消息（可能端口號與配置文件保持一致，或與發(fā)送端口保持一致）
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning #加了--from-beginning 重頭消費所有的消息./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test #不加--from-beginning 從最新的一條消息開始消費
9、查看某個topic對應(yīng)的消息數(shù)量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1
10、顯示所有消費者
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
11、獲取正在消費的topic（console-consumer-63307）的group的offset
./kafka-consumer-groups.sh --describe --group console-consumer-63307 --bootstrap-server localhost:9092
11、顯示消費者
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
分享名稱：簡單介紹一下kafka常用命令
路徑分享：http://www.5511xx.com/article/dpcjheo.html
