Linux系統(tǒng)中如何安裝配置Kafka

這篇文章主要為大家展示了Linux系統(tǒng)中如何安裝配置Kafka，內(nèi)容簡而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶大家一起來研究并學習一下“Linux系統(tǒng)中如何安裝配置Kafka”這篇文章吧。

Linux系統(tǒng)安裝配置Kafka具體步驟

下載Kafka

http://archive.apache.org/dist/kafka/1.1.0/

解壓并重命名

 cd /usr/local
 tar zxvf kafka_2.12-1.1.0.tgz
 mv kafka_2.12-1.1.0 kafka_2.12-1.1.0/

配置kafka

 mkdir /usr/local/kafka/log/kafka #創(chuàng)建kafka日志目錄
 cd /usr/local/kafka/config #進入配置目錄
 vi server.properties #編輯修改相應的參數(shù)
 
 broker.id=0
 port=9092 #端口號
 host.name=hostname #hostname
 listeners=PLAINTEXT://hostname:9092
 log.dirs=/usr/local/kafka/log/kafka #日志存放路徑，上面創(chuàng)建的目錄
 zookeeper.connect=localhost:2181 #zookeeper地址和端口，單機配置部署，localhost:2181

配置zookeeper

 mkdir /usr/local/kafka/zookeeper #創(chuàng)建zookeeper目錄
 mkdir /usr/local/kafka/log/zookeeper #創(chuàng)建zookeeper日志目錄
 cd /usr/local/kafka/config #進入配置目錄
 vi zookeeper.properties #編輯修改相應的參數(shù)
 
 dataDir=/usr/local/kafka/zookeeper #zookeeper數(shù)據(jù)目錄
 dataLogDir=/usr/local/kafka/log/zookeeper #zookeeper日志目錄
 clientPort=2181
 maxClientCnxns=100
 tickTime=2000
 initLimit=10
 syncLimit=5

以上配置使用了kafka自動的zookeeper，無需單獨安裝一個zookeeper

啟動腳本

 vi kafkastart.sh     #編輯，添加以下代碼
 
 #!/bin/sh
 
 #啟動zookeeper
 /usr/local/kafka/bin/zookeeper-server-start.sh /usr/local/kafka/config/zookeeper.properties &
 
 sleep 3   #等3秒后執(zhí)行
 
 #啟動kafka
 /usr/local/kafka/bin/kafka-server-start.sh /usr/local/kafka/config/server.properties &

停止腳本

 vi kafkastop.sh #編輯，添加以下代碼
 
 #!/bin/sh
 
 #關閉zookeeper
 /usr/local/kafka/bin/zookeeper-server-stop.sh /usr/local/kafka/config/zookeeper.properties &
 
 sleep 3 #等3秒后執(zhí)行
 
 #關閉kafka
 /usr/local/kafka/bin/kafka-server-stop.sh /usr/local/kafka/config/server.properties &

創(chuàng)建一個Topic

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

上述命令為創(chuàng)建一個副本數(shù)為1，分區(qū)數(shù)為1的，名字為test的topic

查看Topic

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

發(fā)送消息

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

消費消息

 bin/kafka-console-consumer.sh --bootstrap-server hostname:9092 --topic test --from-beginning

注意hostname和配置中的hostname必須一致

什么是Linux系統(tǒng)

Linux是一種免費使用和自由傳播的類UNIX操作系統(tǒng)，是一個基于POSIX的多用戶、多任務、支持多線程和多CPU的操作系統(tǒng)，使用Linux能運行主要的Unix工具軟件、應用程序和網(wǎng)絡協(xié)議。

以上就是關于“Linux系統(tǒng)中如何安裝配置Kafka”的內(nèi)容，如果該文章對您有所幫助并覺得寫得不錯，勞請分享給您的好友一起學習新知識，若想了解更多相關知識內(nèi)容，請多多關注億速云行業(yè)資訊頻道。