1、Java環(huán)境為前提

（1）上傳jdk-8u261-linux-x64.rpm到服務器并安裝：

成都創(chuàng)新互聯(lián)為客戶提供專業(yè)的網站建設、成都網站制作、程序、域名、空間一條龍服務，提供基于WEB的系統(tǒng)開發(fā). 服務項目涵蓋了網頁設計、網站程序開發(fā)、WEB系統(tǒng)開發(fā)、微信二次開發(fā)、手機網站制作等網站方面業(yè)務。

rpm -ivh jdk-8u261-linux-x64.rpm

（2）配置環(huán)境變量：

vim /etc/profile

# 生效
source /etc/profile
# 驗證
java -version

2、Zookeeper的安裝配置?

（1）上傳zookeeper-3.4.14.tar.gz到服務器

（2）解壓到/opt：

tar -zxf zookeeper-3.4.14.tar.gz -C /opt
cd /opt/zookeeper-3.4.14/conf

# 復制zoo_sample.cfg命名為zoo.cfg
cp zoo_sample.cfg zoo.cfg

# 編輯zoo.cfg文件
vim zoo.cfg

（3）修改Zookeeper保存數(shù)據(jù)的目錄，dataDir：

dataDir=/var/lagou/zookeeper/data

（4）編輯/etc/profile：

• 設置環(huán)境變量ZOO_LOG_DIR，指定Zookeeper保存日志的位置；
• ZOOKEEPER_PREFIX指向Zookeeper的解壓目錄；
• 將Zookeeper的bin目錄添加到PATH中：

（5）?使配置生效

source /etc/profile

（6）驗證：

3、Kafka的安裝與配置

（1）上傳kafka_2.12-1.0.2.tgz到服務器并解壓：

tar -zxf kafka_2.12-1.0.2.tgz -C /opt

（2）配置環(huán)境變量并生效：

vim /etc/profile

（3）?配置/opt/kafka_2.12-1.0.2/config中的server.properties文件：

Kafka連接Zookeeper的地址，此處使用本地啟動的Zookeeper實例，連接地址是localhost:2181，后面的myKafka 是Kafka在Zookeeper中的根節(jié)點路徑：

配置kafka日志存儲目錄?

log.dir=/var/kafka/kafka-logs

（4）啟動Zookeeper：

zkServer.sh start

（5）確認Zookeeper的狀態(tài)：

（6）?啟動Kafka：進入Kafka安裝的根目錄，執(zhí)行如下命令：

啟動成功，可以看到控制臺輸出的最后一行的started狀態(tài)：?

（7）?查看Zookeeper的節(jié)點：（zkCli.sh 命令進入zookeeper控制臺）

（8）此時Kafka是前臺模式啟動，要停止，使用Ctrl+C。

如果要后臺啟動，使用命令：

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

查看Kafka的后臺進程：

ps aux | grep kafka

停止后臺運行的Kafka：

4、生產與消費 4.1、kafka-topics.sh 用于管理主題。

# 列出現(xiàn)有的主題
[root@node1 ~]# kafka-topics.sh --list --zookeeper localhost:2181/myKafka
# 創(chuàng)建主題，該主題包含一個分區(qū)，該分區(qū)為Leader分區(qū)，它沒有Follower分區(qū)副本。
[root@node1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --create --topic topic_1 --partitions 1 --replication-factor 1
# 查看分區(qū)信息
[root@node1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --list
# 查看指定主題的詳細信息
[root@node1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --describe --topic topic_1
# 刪除指定主題
[root@node1 ~]# kafka-topics.sh --zookeeper localhost:2181/myKafka --delete --topic topic_1

4.2、kafka-console-producer.sh用于生產消息：

# 開啟生產者
[root@node1 ~]# kafka-console-producer.sh --topic topic_1 --broker-list localhost:9092

4.3、3、kafka-console-consumer.sh用于消費消息：

# 開啟消費者
[root@node1 ~]# kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_1
# 開啟消費者方式二，從頭消費，不按照偏移量消費
[root@node1 ~]# kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic_1 --from-beginning

你是否還在尋找穩(wěn)定的海外服務器提供商？創(chuàng)新互聯(lián)www.cdcxhl.cn海外機房具備T級流量清洗系統(tǒng)配攻擊溯源，準確流量調度確保服務器高可用性，企業(yè)級服務器適合批量采購，新人活動首月15元起，快前往官網查看詳情吧

文章名稱：Kafka安裝與配置-創(chuàng)新互聯(lián)
路徑分享：http://weahome.cn/article/djjpdg.html