Linux系統如何安裝Kafka

小編給大家分享一下Linux系統如何安裝Kafka，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

Kafka是一種高吞吐量的分布式發布訂閱消息系統，它可以處理消費者在網站中的所有動作流數據。

Kafka簡介：

Kafka是一個分布式消息隊列。★Kafka對消息保存時根據Topic進行歸類，發送消息者稱為Producer，消息接受者稱為Consumer，此外kafka集群有多個kafka實例組成，每個實例(server)稱為broker。無論是kafka集群，還是consumer都依賴于zookeeper集群保存一些meta信息，來保證系統可用性。

Linux系統安裝Kafka具體步驟：

Kafka下載    官網下載地址  http://kafka.apache.org/downloads    demo用的版本  https://archive.apache.org/dist/kafka/1.0.0/kafka_2.12-1.0.0.tgz

解壓到安裝目錄下    tar -zxvf kafka_2.12-1.0.0.tgz    mv kafka_2.12-1 /usr/local/kafka

配置    #創建日志存放目錄，默認Kafka運行的時候都會通過log4j打印很多日志文件，比如server.log, controller.log, state-change.log等，而都會將其輸出到$KAFKA_HOME/logs目錄下，這樣不利于線上運維，因為經常容易出現打爆文件系統

 #這里我們把日志目錄指向var目錄下
 cd /var/local
 mkdir -p kafka-logs
 
 #修改配置文件/opt/kafka/config/server.properties
 vi /usr/local/kafka/config/server.properties
 
 #主要修改下面幾項內容如下：

broker.id=181 delete.topic.enable=true listeners = PLAINTEXT://192.168.0.166:9092 log.dirs=/var/local/kafka-logs zookeeper.connect=127.0.0.1:2181

添加系統環境變量    vi /etc/profile    #添加如下內容：

KAFKA_HOME=/usr/local/kafka PATH=KAFKA_HOME/bin export PATH KAFKA_HOME

啟動、測試    kafka-server-start.sh /usr/local/kafka/config/server.properties    #發送    ./kafka-console-producer.sh –broker-list 192.168.0.166:9092 –topic test1    #接收    ./kafka-console-consumer.sh –zookeeper 192.168.0.166:2181 -topic test1 –from-beginning

開機啟動    #在init.d目下創建kafka腳本文件

 cd /etc/rc.d/init.d
 
 touch kafka
 
 vi kafka

 #編輯下面內容

#!/bin/bash

#chkconfig:2345 30 80 #description:kafka #processname:kafka export JAVA_HOME=/usr/local/jvm/jdk1.8.0_201 export KAFKA_HOME=/usr/local/kafka case {KAFKA_HOME}/bin/kafka-server-start.sh -daemon {KAFKA_HOME}/bin/kafka-server-stop.sh            ;;        status)            jps            ;;        restart)  {KAFKA_HOME}/bin/kafka-server-start.sh -daemon ${KAFKA_HOME}/config/server.properties            ;;        *)            echo “require start|stop|status|restart”            ;; esac    #權限

 chmod 755 kafka
 
 #測試一下
 
 service kafka start
 
 #添加到服務列表
 
 chkconfig --add kafka
 
 chkconfig --list
 
 chkconfig kafka on

遇到的坑 Kafka進程總是在啟動一段時間后自動停止 使用-daemon守護進程啟動 kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties

以上是“Linux系統如何安裝Kafka”這篇文章的所有內容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內容對大家有所幫助，如果還想學習更多知識，歡迎關注億速云行業資訊頻道！