新聞中心
Kafka是一個(gè)分布式、分區(qū)的、多副本的、多訂閱者,基于zookeeper協(xié)調(diào)的分布式日志系統(tǒng)(也可以當(dāng)做MQ系統(tǒng)),常見(jiàn)可以用于web/nginx日志、訪問(wèn)日志,消息服務(wù)等等,本篇文章重點(diǎn)為大家講解一下kafka常用命令。

為白沙黎族等地區(qū)用戶提供了全套網(wǎng)頁(yè)設(shè)計(jì)制作服務(wù),及白沙黎族網(wǎng)站建設(shè)行業(yè)解決方案。主營(yíng)業(yè)務(wù)為做網(wǎng)站、成都網(wǎng)站設(shè)計(jì)、白沙黎族網(wǎng)站設(shè)計(jì),以傳統(tǒng)方式定制建設(shè)網(wǎng)站,并提供域名空間備案等一條龍服務(wù),秉承以專業(yè)、用心的態(tài)度為用戶提供真誠(chéng)的服務(wù)。我們深信只要達(dá)到每一位用戶的要求,就會(huì)得到認(rèn)可,從而選擇與我們長(zhǎng)期合作。這樣,我們也可以走得更遠(yuǎn)!
1、啟動(dòng)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、查看所有話題的詳細(xì)信息
./kafka-topics.sh --zookeeper localhost:2181 --describe
5、列出指定話題的詳細(xì)信息
./kafka-topics.sh --zookeeper localhost:2181 --describe --topic demo
6、刪除一個(gè)話題
./kafka-topics.sh --zookeeper localhost:2181 --delete --topic test
7、創(chuàng)建一個(gè)叫test的話題,有兩個(gè)分區(qū),每個(gè)分區(qū)3個(gè)副本
./kafka-topics.sh --zookeeper localhost:2181 --create --topic test --replication-factor 3 --partitions 2
8、測(cè)試kafka發(fā)送和接收消息(啟動(dòng)兩個(gè)終端)
#發(fā)送消息(注意端口號(hào)為配置文件里面的端口號(hào))
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
#消費(fèi)消息(可能端口號(hào)與配置文件保持一致,或與發(fā)送端口保持一致)
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning #加了--from-beginning 重頭消費(fèi)所有的消息./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test #不加--from-beginning 從最新的一條消息開(kāi)始消費(fèi)
9、查看某個(gè)topic對(duì)應(yīng)的消息數(shù)量
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1
10、顯示所有消費(fèi)者
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
11、獲取正在消費(fèi)的topic(console-consumer-63307)的group的offset
./kafka-consumer-groups.sh --describe --group console-consumer-63307 --bootstrap-server localhost:9092
11、顯示消費(fèi)者
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
本文題目:簡(jiǎn)單介紹一下kafka常用命令
URL標(biāo)題:http://www.dlmjj.cn/article/dpcjheo.html


咨詢
建站咨詢
