Kafka安裝與配置-創(chuàng)新互聯(lián)

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

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

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

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

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

vim /etc/profile

# 生效
source /etc/profile
# 驗(yàn)證
java -version

2、Zookeeper的安裝配置?

（1）上傳zookeeper-3.4.14.tar.gz到服務(wù)器

（2）解壓到/opt：

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

# 復(fù)制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：

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

（5）?使配置生效

source /etc/profile

（6）驗(yàn)證：

3、Kafka的安裝與配置

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

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的地址，此處使用本地啟動(dòng)的Zookeeper實(shí)例，連接地址是localhost:2181，后面的myKafka 是Kafka在Zookeeper中的根節(jié)點(diǎn)路徑：

配置kafka日志存儲(chǔ)目錄?

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

（4）啟動(dòng)Zookeeper：

zkServer.sh start

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

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

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

（7）?查看Zookeeper的節(jié)點(diǎn)：（zkCli.sh 命令進(jìn)入zookeeper控制臺(tái)）

（8）此時(shí)Kafka是前臺(tái)模式啟動(dòng)，要停止，使用Ctrl+C。

如果要后臺(tái)啟動(dòng)，使用命令：

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

查看Kafka的后臺(tái)進(jìn)程：

ps aux | grep kafka

停止后臺(tái)運(yùn)行的Kafka：

4、生產(chǎn)與消費(fèi) 4.1、kafka-topics.sh 用于管理主題。

# 列出現(xiàn)有的主題
[root@node1 ~]# kafka-topics.sh --list --zookeeper localhost:2181/myKafka
# 創(chuàng)建主題，該主題包含一個(gè)分區(qū)，該分區(qū)為L(zhǎng)eader分區(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
# 查看指定主題的詳細(xì)信息
[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用于生產(chǎn)消息：

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

4.3、3、kafka-console-consumer.sh用于消費(fèi)消息：

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

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

分享文章：Kafka安裝與配置-創(chuàng)新互聯(lián)
分享URL：http://www.muchs.cn/article16/djjpdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供用戶體驗(yàn)、企業(yè)建站、商城網(wǎng)站、面包屑導(dǎo)航、外貿(mào)網(wǎng)站建設(shè)、定制開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)