這篇文章主要介紹CentOS7怎么安裝Kafka，文中介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們一定要看完！

方正網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián)公司,方正網(wǎng)站設(shè)計(jì)制作，有大型網(wǎng)站制作公司豐富經(jīng)驗(yàn)。已為方正數(shù)千家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\外貿(mào)網(wǎng)站建設(shè)要多少錢，請(qǐng)找那個(gè)售后服務(wù)好的方正做網(wǎng)站的公司定做！

簡(jiǎn)介

Kafka 是一種高吞吐的分布式發(fā)布訂閱消息系統(tǒng)，能夠替代傳統(tǒng)的消息隊(duì)列用于解耦合數(shù)據(jù)處理，緩存未處理消息等，同時(shí)具有更高的吞吐率，支持分區(qū)、多副本、冗余，因此被廣泛用于大規(guī)模消息數(shù)據(jù)處理應(yīng)用

Kafka 支持Java 及多種其它語(yǔ)言客戶端，可與Hadoop、Storm、Spark等其它大數(shù)據(jù)工具結(jié)合使用。

本教程主要介紹Kafka 在Centos 7上的安裝和使用，包括功能驗(yàn)證和集群的簡(jiǎn)單配置。

安裝JDK

Kafka 使用Zookeeper 來保存相關(guān)配置信息，Kafka及Zookeeper 依賴Java 運(yùn)行環(huán)境，從oracle網(wǎng)站下載JDK 安裝包，解壓安裝：

$tar zxvf jdk-8u65-linux-x64.tar.gz
$mv jdk1.8.0_65 java

設(shè)置Java 環(huán)境變量：

JAVA_HOME=/opt/java
PATH=$PATH:$JAVA_HOME/bin
export JAVA_HOME PATH

也可以選擇yum install安裝，相應(yīng)設(shè)置環(huán)境變量。

安裝Kafka

從官網(wǎng)下載Kafka 安裝包，解壓安裝： 官網(wǎng)地址：http://kafka.apache.org/downloads.html

tar zxvf kafka_2.11-0.8.2.2.tgz
mv kafka_2.11-0.8.2.2 kafka
cd kafka

功能驗(yàn)證

1.啟動(dòng)Zookeeper 使用安裝包中的腳本啟動(dòng)單節(jié)點(diǎn)Zookeeper 實(shí)例：

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

2.啟動(dòng)Kafka 服務(wù) 使用kafka-server-start.sh 啟動(dòng)kafka 服務(wù)：

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

3.創(chuàng)建topic 使用kafka-topics.sh 創(chuàng)建單分區(qū)單副本的topic test：

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

查看topic：

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

4.產(chǎn)生消息 使用kafka-console-producer.sh 發(fā)送消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
Hello world！

5.消費(fèi)消息 使用kafka-console-consumer.sh 接收消息并在終端打?。?/p>

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

producer產(chǎn)生的消息和consumer消費(fèi)的消息是同步的。

以上是“CentOS7怎么安裝Kafka”這篇文章的所有內(nèi)容，感謝各位的閱讀！希望分享的內(nèi)容對(duì)大家有幫助，更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！