進入kafka官網：
source download需要編譯才能使用
】以下用kafka_2.10-0.9.0.0.tgz
版本
tar -xzvfkafka_2.10-0.9.0.0.tgz
cd kafka_2.10-0.9.0.0
目錄：/bin 啟動和停止命令等。
/config 配置檔案
/libs 類庫
啟動zookeeper server：
bin/zookeeper-server-start.sh config/zookeeper.properties &
&是為了能退出命令列
啟動kafka server:
bin/kafka-server-start.sh config/server.properties &
停止kafka server:
bin/kafka-server-stop.sh
停止zookeeper server:
bin/zookeeper-server-stop.sh
執行producer：
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
早版本的kafka，--broker-list localhost:9092需改為--zookeeper localhost:2181
執行consumer：
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
在producer端輸入字串並回車，檢視consumer端是否顯示。
zookeeper server, kafka server, producer都放在伺服器server1上，ip位址為192.168.1.10
consumer放在伺服器server2上，ip位址為192.168.1.12。
分別執行server1的producer和server2的consumer:
bin/kafka-console-producer.sh --broker-list 192.168.1.10:9092 --topic test
bin/kafka-console-consumer.sh --zookeeper 192.168.1.10:2181 --topic test --from-beginning
在producer的console端輸入字串，consumer報
connection refused
錯誤：
broker, producer和consumer都註冊到zookeeper上，producer和consumer的引數明確指定。問題出在broker的配置檔案server.properties上：
# hostname the broker will bind to. if not set, the server will bind to all inte***ces
#host.name=localhost
host名稱沒有指定，就是127.0.0.1，consumer去broker拿資料就有問題。設定為192.168.1.10，重啟服務就好了。
怎麼安裝VMwaretools在Linux系統裡
vmwaretools是vmware虛擬機器中很重要的乙個工具包，有些時候在虛擬機器中安裝完作業系統會缺少網絡卡驅動，不能上網，這時只要安裝vmwaretools就可以解決問題，下面以centos為例，來說明vmwaretools的安裝方法 1 開啟vmware workstation虛擬機器，開啟...
Kafka Kafka集群操作
首先進入到kafka的安裝目錄下 cd export servers kafka 2.11 1.0.0建立乙個名字為test的主題，有三個分割槽，有兩個副本 node01執行以下命令來建立topic cd export servers kafka 2.11 1.0.0 bin kafka topic...
Kafka Kafka安裝部署
hadoop102 hadoop103 hadoop104 zk zk zk kafka kafka kafka 1 解壓安裝包 ck hadoop102 software tar zxvf kafka 2.12 2.6.1.tgz c opt module 2 在 opt module kafka...