kafka安裝配置

2021-09-27 08:57:35 字數 959 閱讀 3318

2、安裝成功後,啟動命令:

先啟動zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties &

再啟動kafka

bin/kafka-server-start.sh config/server.properties &

3、測試kafka是否可用

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testtopic

建立好之後,可以通過執行以下命令,檢視已建立的topic資訊:

bin/kafka-topics.sh --list --zookeeper localhost:2181

4、傳送訊息

kafka提供了乙個命令列的工具,可以從輸入檔案或者命令列中讀取訊息並傳送給kafka集群。每一行是一條訊息。

執行producer(生產者),然後在控制台輸入幾條訊息到伺服器。

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testtopic test message test messages

5、消費訊息

kafka也提供了乙個消費訊息的命令列工具,將儲存的資訊輸出出來。

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testtopic --from-beginning test message test messages

springboot啟動一直重新整理找不到主機名

外網如何設定訪問伺服器上kafka,修改server.properties配置就可以

advertised.listeners=plaintext:

Kafka安裝配置

kafka執行依賴 zookeeper,如未安裝zookeeper請參考 zookeeper安裝使用 kafka版本問題 這又是一大坑 如果你的storm安裝的是1.0.x系列或更低的版本,建議你安裝0.8.x.x版本的kafka。如果你的storm安裝的是1.1.x系列或更高的版本,建議你安裝0....

kafka安裝配置

一.zookeeper部署 tar xvf zookeeper 3.4.6.tar.gz mv zookeeper 3.4.6 zookeeper chown r root root zookeeper 2.修改配置 cd zookeeper conf cp zoo sample.cfg zoo.c...

kafka安裝配置

1 部署規劃 作業系統 centos 7.2 kafka版本 kafka 2.10 0.8.2.1 安裝路徑 opt kafka 2.10 0.8.2.1 節點 192.168.20.100 105 2 部署過程 2.2 解壓 tar zxvf kafka 2.10 0.8.2.1.tgz 2.3 ...