Kafka入門 3 kafka基礎操作

建立乙個topic（主題）。kafka中所有的訊息都是儲存在主題中，要生產訊息到kafka，首先必須要有乙個確定的主題。

# 建立名為test的主題

bin/kafka-topics.sh --create --bootstrap-server node1:9092 --topic test
# 檢視目前kafka中的主題
bin/kafka-topics.sh --list --bootstrap-server node1:9092

bin/kafka-console-producer.sh --broker-list node1:9092 --topic test

3 Kafka集群部署

1 解壓安裝包 2 修改解壓後的檔名稱 ip101 mv kafka 2.11 0.11.0.0 kafka ip101 mkdir logs 4 修改配置檔案 ip101 cd config test ip101 config vi server.properties 輸入以下內容 broker的...

3 Kafka安裝及部署

配置主機名對映。vi etc hosts 新增如下內容 168.5.7.75 server1 168.5.7.76 server2 168.5.7.77 server3分別登入server1 server2 server3執行，操作 配置相同 更新或安裝wget命令 yum y install wg...

kafka入門基礎

分布式訊息系統，由linkedin使用scala編寫，用作linkedin的活動流 activity stream 和運營資料處理管道 pipeline 的基礎。具有高水平擴充套件和高吞吐量.當前由apache開源.整個系統由生產者 broker server和消費者三部分組成，生產者和消費者由開發...