tar -zxvf kafka_2.12-2.2.0
3.修改配置檔案
#mkdir logs；
#vi server.properties #編輯修改相應的引數
broker.id=1
port=9092 #kafka埠號（固定的）
host.name=192.168.199.131 #伺服器ip位址，修改為自己的伺服器ip
zookeeper.connect=localhost:2181 #zookeeper位址和埠
#：wq! 儲存退出
檢視自己的伺服器ip，在虛擬機器上查詢
注：這樣kafka就安裝好了，但是先不要啟動。
啟動kafka之前要啟動zookeeper，否則會出現「拒接連線」錯誤
指令碼啟動：
./zkmanager.sh start
啟動zookeeper成功後會看到如下輸出：
進入kafka目錄：
輸入：./kafka-server-start.sh ../config/server.properties &
啟動kafka成功後會看到如下的輸出:
在kafka目錄下，輸入：
bin/kafka-topics.sh --create --zookeeper hdp-1:2181,hdp-2:2181,hdp-3:2181 --replication-factor 1 --partitions 1 --topicaaa
建立乙個名為aaa的topic
在建立topic後可以通過輸入
bin/kafka-topics.sh --list --zookeeper hdp-1:2181,hdp-2:2181,hdp-3:2181
來檢視已經建立的topic
刪除建立的topic:
bin/kafka-topics.sh --delete --zookeeper hdp-1:2181,hdp-2:2181,hdp-3:2181 test
在kafka目錄下 輸入：
bin/kafka-console-consumer.sh --bootstrap-server hdp-1:9092,hdp-2:9092,hdp-3:9092 --topic test --from-beginning
1.可以建立乙個用於消費topic為test的消費者
消費者建立完成之後，因為還沒有傳送任何資料，因此這裡在執行後沒有列印出任何資料，不過別著急，不要關閉這個終端，開啟乙個新的終端，接下來我們建立第乙個訊息生產者
2.建立乙個訊息產生者:
在kafka目錄下，輸入：
bin/kafka-console-producer.sh --broker-list hdp-1:9092,hdp-2:9092,hdp-3:9092 --topic test
在傳送完訊息之後，可以回到我們的訊息消費者終端中，可以看到，終端中已經列印出了我們剛才傳送的訊息。
注：其實就是在訊息產生者輸入訊息，在訊息消費者可以收到訊息。這樣就測試kafka成功
linux在虛擬機上安裝
file new virtual machine next e 開發工具 linux linuxrh4 as4 1.iso next 隨便填 next next 關閉執行 edit virtual machine settings 將用不上的刪除 cd ide floppy 軟盤 usb contr...
DPDK pktgen在虛擬機上安裝
正文 環境 虛擬機器vmware12 pro dpdk 16.04 pktgen 3.3.0 準備工作 1.本人之前已經編譯安裝過dpdk，基本環境具備 步驟 ps 以下操作在root下執行。有些操作需要root許可權，便於操作所以建議直接切換到root 2.開啟命令列，進入dpdk目錄，執行.to...
在虛擬機上安裝RabbitMQ
4.使用者角色 5.使用者許可權 使用vmware安裝映象 設定系統為可連線網際網路 我使用介面卡橋接模式 可選 設定允許root遠端登入sudo vim etc ssh sshd config，找到permitrootlogin without password 修改為permitrootlogi...