kafka2 10 0 10 0 1版相關命令

2021-10-09 13:06:50 字數 600 閱讀 7888

路徑 cd /data/kafka_*

檢視kafka訊息日誌(加粗指的是topic(你們直接使用你們的topic就好);localhost:2181指的是zookeeper的訪問埠;)

1.檢視當前kafka的所有的topic

bin/kafka-topics.sh --list --zookeeper localhost:2181

2.檢視對應topic的訊息

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group * |greptest

3.檢視topic的消費者

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topictest--from-beginning

4.檢視消費情況

bin/kafka-consumer-groups.sh --bootstrap-server localhost:2181 --describe --group group-k |greptest

單機版kafka安裝

export server kafka kafka安裝需要有zookeeper註冊中心 其中 zookeeper的安裝 見centos7安裝偽分布式zookeeper root vm 0 2 centos kafka wget2.解壓 root vm 0 2 centos kafka tar zxv...

單機版kafka安裝

wget解壓安裝包 tar xzvf kafka 2.11 2.0.0.tgz修改server.properties檔案 vim kafka 2.11 2.0.0 config server.properties listeners plaintext advertised.listeners pl...

kafka集群配置 windows版

1.拷貝conf server.properties為 第乙個節點server 9093.properties,修改如下內容 broker.id 9093 port 9093 host.name 127.0.0.1 log.dirs tmp kafka logs 9093 zookeeper.con...