天貓精靈Sound Pro體驗(yàn)：智能音箱沒(méi)有音質(zhì)？來(lái)聽(tīng)聽(tīng)我的
這幾年除了手機(jī)作為智能生活終端最主要的核心之外，第二個(gè)可以成為中心點(diǎn)的產(chǎn)品是什么？——是智能音箱。 手機(jī)在執(zhí)行命令的時(shí)候有兩種操作方式，手和智能語(yǔ)音助手，而智能音箱只
圖片
hostnamectl set-hostname kafka1hostnamectl set-hostname kafka2hostnamectl set-hostname kafka3在Windows系統(tǒng)中修改hosts文件，填入如下內(nèi)容：
192.168.150.111 kafka1192.168.150.112 kafka2192.168.150.113 kafka3
圖片
image
圖片
在3臺(tái)Linux的/etc/hosts文件中，填入如下內(nèi)容（3臺(tái)都要添加）。
192.168.150.111 kafka1192.168.150.112 kafka2192.168.150.113 kafka3后續(xù)安裝的集群化軟件，多數(shù)需要遠(yuǎn)程登錄以及遠(yuǎn)程執(zhí)行命令，我們可以簡(jiǎn)單起見(jiàn)，配置三臺(tái)Linux服務(wù)器之間的免密碼互相SSH登陸。
在每一臺(tái)機(jī)器都執(zhí)行：
ssh-keygen -t rsa -b 4096一路回車(chē)到底即可 2. 在每一臺(tái)機(jī)器都執(zhí)行：
ssh-copy-id kafka1ssh-copy-id kafka2ssh-copy-id kafka3執(zhí)行完畢后，kafka1、kafka2、kafka3之間將完成root用戶之間的免密互通。
ssh rootmkafka1ssh root@kafka2ssh root@kafka3#1. 安裝ntp軟件yum install -y ntp#2. 更新時(shí)區(qū)rm -f /etc/localtime;sudo ln -s /usr/share/zoneinfo/Asia/Shanghai /etc/localtime#3. 同步時(shí)間ntpdate -u ntp.aliyun.com#4. 開(kāi)啟ntp服務(wù)并設(shè)置開(kāi)機(jī)自啟systemctl start ntpdsystemctl enable ntpd當(dāng)前使用發(fā)行版：3.8.4版。
可以在https://downloads.apache.org/zookeeper/選擇對(duì)應(yīng)版本下載：
圖片
注意:以下操作,kafka1節(jié)點(diǎn)執(zhí)行,以root身份登陸。
1.上傳zookeeper安裝包到kafka1節(jié)點(diǎn)中。
2.創(chuàng)建/export/server/。
mkdir -p /export/server/解壓縮安裝包到/export/server/中。
tar -zxvf apache-zookeeper-3.8.4.tar.gz -C /export/server/3.在 cd /export/server/apache-zookeeper-3.8.4-bin/conf/創(chuàng)建zoo.cfg。
# 復(fù)制zoo_sample.cfg命名為zoo.cfgcp zoo_sample.cfg zoo.cfg4.修改Zookeeper保存數(shù)據(jù)的目錄。
mkdir -p /export/server/apache-zookeeper-3.8.4-bin/data5.編輯zoo.cfg文件。
vim zoo.cfg內(nèi)容如下:
# The number of milliseconds of each ticktickTime=2000# The number of ticks that the initial # synchronization phase can takeinitLimit=10# The number of ticks that can pass between # sending a request and getting an acknowledgementsyncLimit=5# the directory where the snapshot is stored.# do not use /tmp for storage, /tmp here is just # example sakes.dataDir=/export/server/apache-zookeeper-3.8.4-bin/data# the port at which the clients will connectclientPort=2181server.1=192.168.150.111:2888:3888server.2=192.168.150.112:2888:3888server.3=192.168.150.113:2888:3888
圖片
創(chuàng)建myid文件，配置服務(wù)器編號(hào) 服務(wù)器zookeeper的dataDir對(duì)應(yīng)目錄下創(chuàng)建 myid 文件，內(nèi)容為對(duì)應(yīng)ip的zookeeper服務(wù)器編號(hào)。
mkdir -p /export/server/apache-zookeeper-3.8.4-bin/dataecho 1 > /export/server/apache-zookeeper-3.8.4-bin/data/myid7.分發(fā)zookeeper文件夾
# 在kafka1執(zhí)行如下命令cd /export/serverscp -r /export/server/apache-zookeeper-3.8.4-bin kafka2:`pwd`/scp -r /export/server/apache-zookeeper-3.8.4-bin kafka3:`pwd`/8.在kafka2上修改myid
echo 2 > /export/server/apache-zookeeper-3.8.4-bin/data/myid9.在kafka3上修改myid
echo 3 > /export/server/apache-zookeeper-3.8.4-bin/data/myid本次使用的Kafka版本為2.4.1，是2020年3月12日發(fā)布的版本。 可以注意到Kafka的版本號(hào)為：kafka_2.12-2.4.1，因?yàn)閗afka主要是使用scala語(yǔ)言開(kāi)發(fā)的，2.12為scala的版本號(hào)。http://kafka.apache.org/downloads可以查看到每個(gè)版本的發(fā)布時(shí)間。
圖片
1.將Kafka的安裝包上傳到虛擬機(jī)。
tar -zxvf kafka_2.12-2.4.1.tgz -C /export/server/ cd /export/server/kafka_2.12-2.4.1/2.修改 server.properties。
cd /export/server/kafka_2.12-2.4.1/configvim server.properties內(nèi)容如下：
# 指定broker的idbroker.id=0# 指定Kafka數(shù)據(jù)的位置log.dirs=/export/server/kafka_2.12-2.4.1/data# 配置zk的三個(gè)節(jié)點(diǎn)zookeeper.cnotallow=kafka1:2181,kafka2:2181,kafka3:21813.將安裝好的kafka復(fù)制到另外兩臺(tái)服務(wù)器。
cd /export/serverscp -r apache-zookeeper-3.8.4 kafka2:`pwd`/scp -r apache-zookeeper-3.8.4 kafka3:`pwd`/4.修改另外兩個(gè)節(jié)點(diǎn)的broker.id分別為1和2。
---------kafka1--------------cd /export/server/kafka_2.12-2.4.1/configvim erver.propertiesbroker.id=1---------kafka2--------------cd /export/server/kafka_2.12-2.4.1/configvim erver.propertiesbroker.id=2vim /etc/profileJAVA_HOME=/export/server/jdk1.8.0_361KAFKA_HOME=/export/server/kafka_2.12-2.4.1ZOKEEPER_HOME=/export/server/apache-zookeeper-3.8.4-bin/PATH=$PATH:$JAVA_HOME/bin:$KAFKA_HOME/bin:$ZOKEEPER_HOME/binexport PATH分發(fā)到各個(gè)節(jié)點(diǎn)scp /etc/profile kafka2:$PWDscp /etc/profile kafka2:$PWD每個(gè)節(jié)點(diǎn)加載環(huán)境變量source /etc/profile1.在三臺(tái)機(jī)器上啟動(dòng)Zookeeper。
zkServer.sh start
圖片
2.在三臺(tái)機(jī)器上查看Zookeeper狀態(tài)。
zkServer.sh status
圖片
圖片
[root@kafka1 ~]# kafka-server-start.sh /export/server/kafka_2.12-2.4.1/config/server.properties[root@kafka2 ~]# kafka-server-start.sh /export/server/kafka_2.12-2.4.1/config/server.properties[root@kafka3 ~]# kafka-server-start.sh /export/server/kafka_2.12-2.4.1/config/server.propertieskafka1節(jié)點(diǎn)的Cluster Id：
圖片
kafka2節(jié)點(diǎn)的Cluster Id：
圖片
kafka3節(jié)點(diǎn)的Cluster Id：
圖片
1.創(chuàng)建主題(名字叫test)：
kafka-topics.sh --create --bootstrap-server kafka1:9092 --topic test2.查詢當(dāng)前kafka的所有主題：
kafka-topics.sh --bootstrap-server kafka3:9092 --list
本文鏈接：http://m.www897cc.com/showinfo-26-88325-0.html從零開(kāi)始搭建 Kafka集群
聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)