1.環境作業系統為centos linux release 7.2.1511 (core)
可用cat /etc/redhat-release查詢
2.軟體版本
kafka版本為:0.10.0.0
4.啟動kafka服務
[root@centos7 bin]# ps -ef | grep kafka檢視,觀察到zookeeper和kafka服務已啟動
1.建立乙個叫"test1234"的topic,它只有乙個分割槽,乙個副本:
可以用list檢視建立的topic,當前建立了4個topic
2.傳送訊息。執行producer並在控制台中輸一些訊息,這些訊息將被傳送到服務端
3.在另乙個終端開啟consumer,可以讀取到剛才發出的訊息並輸出。
單機版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單機版安裝
參考文件 192.168.1.183 centos 6.5 2.6.32 431.el6.x86 64 三部曲 jdk zookeeper kafka 嚴格的安裝順序 wget wget 1 基本的系統操作 關閉防火牆 時間同步 相關工具.2 安裝jdk root kafka cd usr loca...