路徑 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...