柚子快報激活碼778899分享：CentOS下安裝Kafka3

http://yzkb.51969.com/

? kafka是分布式消息隊列，本文講述其在centos（centos 7.5）下的安裝。安裝過程可以參考其官方文檔https://kafka.apache.org/36/documentation.html

首先在官網(wǎng)?https://kafka.apache.org/downloads 下載Kafka二進制文件（官網(wǎng)的壓縮包里面已經(jīng)包含了Linux和windows的Kafka可執(zhí)行文件了），選擇目前比較新的3.6.1版本下載。

一、安裝Java環(huán)境

?Kafka 是用 Java 開發(fā)的，因此需要安裝java環(huán)境。從Kafka的官方文檔?Apache Kafka 可以看到，Kafka3.6.1需要的java環(huán)境為Java8 或以上（不同版本的Kafka需要的Java環(huán)境版本也不一樣）。

從Java官網(wǎng)Java Downloads | Oracle?下載 JDK（SUN公司提供的一套Java開發(fā)環(huán)境，簡稱JDK(JavaDevelopmentKit)，它是整個Java的核心，其中包括Java編譯器、Java運行工具、Java文檔生成工具、Java打包工具）

將java jdk拷貝到CentOS中，執(zhí)行命令：

tar -zxvf jdk-21_linux-x64_bin.tar.gz

cd jdk-21.0.2

mkdir /usr/lib/jdk

cd ..

mv jdk-21.0.2/ /usr/lib/jdk

配置java環(huán)境變量，將環(huán)境變量配置在etc/profile或/etc/bashrc中

vi /etc/bashrc

在末尾添加以下幾行文字：

#set java env

export JAVA_HOME=/usr/lib/jdk/jdk1.8.0_291

export JRE_HOME=${JAVA_HOME}/jre

export CLASSPATH=.:${JAVA_HOME}/lib:${JRE_HOME}/lib

export PATH=${JAVA_HOME}/bin:$PATH

讓環(huán)境變量生效

source /etc/bashrc

執(zhí)行命令：

java -version

如果出現(xiàn)現(xiàn)版本號說明Java環(huán)境安裝成功：

二、安裝部署Kafka

然后我們來安裝Kafka，將之前下載下來的Kafka二進制文件kafka_2.12-3.6.1.tgz拷貝到CentOS中，執(zhí)行命令：

tar -zxvf kafka_2.12-3.6.1.tgz

mv kafka_2.12-3.6.1 kafka_3.6.1

cd kafka_3.6.1

可以看到目錄結(jié)構(gòu)如下：

.kafka3版本之后自帶zookeeper。配置zookeeper的配置文件：

vi config/zookeeper.properties

設(shè)置快照存貯路徑

配置Kafka的配置文件：

vi config/server.properties

設(shè)置日志文件的存貯路徑：

啟動zookeeper：

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

啟動kafka:

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

通過netstat命令查看到9092端口被一個java進程占用，說明啟動成功了

三、Kafka的基本操作

創(chuàng)建主題：

bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Kafka 中的消息以主題為單位進行歸類，生產(chǎn)者負責(zé)將消息發(fā)送到特定的主題（發(fā)送到 Kafka 集群中的每一條消息都要指定一個主題），而消費者負責(zé)訂閱主題并進行消費。

查看主題屬性：

bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

新建兩個終端，分別執(zhí)行命令，通過生產(chǎn)者發(fā)送消息：

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

通過消費者消費消息：

bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

然后就可以看到生產(chǎn)者和消費者進行通訊了：

四、遇到問題

Kafka生產(chǎn)者、消費者通訊時可能會報錯：Error connecting to node xxxxx:9092，可以參考：《kafka發(fā)送數(shù)據(jù)報錯： Error connecting to node xxxxx:9092 (id: 1 rack: null)java.net.UnknownHostExceptio》

五、相關(guān)文章

Windows下安裝Kafka可以參考《Windows下安裝Kafka3》

柚子快報激活碼778899分享：CentOS下安裝Kafka3

http://yzkb.51969.com/

文章來源