linux下安裝kafka


1、下載kafka

  cd到/usr/local目錄下,執行命令:wget https://www-us.apache.org/dist/kafka/2.4.0/kafka_2.13-2.4.0.tgz下載

2、解壓kafka_2.13-2.4.0.tgz文件

  tar -zxvf kafka_2.13-2.4.0.tgz

3、啟動服務

3.1 啟動zookeeper
    啟動zk有兩種方式,第一種是使用kafka自己帶的一個zk:bin/zookeeper-server-start.sh config/zookeeper.properties 

    另一種是使用其它的zookeeper,可以位於本機也可以位於其它地址。

    這種情況需要修改kafka中config下面的server.properties里面的zookeeper地址 。例如zookeeper.connect=192.168.213.11:2181

    成功啟動zookeeper后才可以啟動kafka。

   3.2 修改kafka下的config/server.properties 

    修改log.dirs=/usr/local/kafka_2.13-2.4.0/kafka_logs   //日志文件路徑  記得創建日志文件目錄

              修改advertised.listeners=PLAINTEXT://192.168.1.19:9092   //配置對外訪問的ip  如果不配置外網無法訪問

   3.2 啟動kafka     

    執行命令:bin/kafka-server-start.sh config/server.properties   啟動kafka 

            kafka如果直接啟動會出現問題,就是信息會打印在控制台,就會出現在控制台。

            然后關閉窗口,kafka隨之關閉,然后啟動以下的命令就可以實現。

            bin/kafka-server-start.sh config/server.properties  1>/dev/null 2>&1 &

4、創建topic

        執行命令: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test  創建topic

  創建一個名為test的topic,只有一個副本,一個分區

  通過list命令查看剛剛創建的topic

       執行命令:bin/kafka-topics.sh -list -zookeeper localhost:2181    查看

5、啟動producer並發送消息啟動producer

 執行命令:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test   啟動producer 

之后就可以發送消息了,例如:
This is a message
This is another message

 6、然后在另一個終端中,啟動consumer

  執行命令:bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM