您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關kafka2.3集群如何搭建的內容。小編覺得挺實用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
環境:
3臺centos7.4
3臺zookeeper3.4.14
wget http://mirror.bit.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
解壓:tar -zxvf kafka_2.11-2.3.0.tgz
進入kafka目錄,修改config/server.properties,找到zookeeper.connect,修改zk集群的連接地址為:
zookeeper.connect=10.99.32.3:2181,10.99.32.31:2181,10.99.32.9:2181
然后修改broker.id=0 //1,2,每個節點的id必須不一樣,否則啟動會報錯
啟動kafka:bin/kafka-server-start.sh -daemon config/server.properties
啟動報錯:org.apache.zookeeper.KeeperException$NodeExistsException: KeeperErrorCode = NodeExists:寫入zk時目錄相同,原因可能是server.properties里面的broker.id=1重復了
啟動成功后使用jps查看運行的,或者使用ps -aux | grep kafka,有記錄即為運行成功
創建topic:
bin/kafka-topics.sh --create --zookeeper 10.99.32.3:2181 --replication-factor 3 --partitions 1 --topic myTopic
顯示topic信息:
bin/kafka-topics.sh --describe --zookeeper 10.99.32.3:2181 --topic myTopic
添加信息節點只需要配置增加即可
感謝各位的閱讀!關于“kafka2.3集群如何搭建”這篇文章就分享到這里了,希望以上內容可以對大家有一定的幫助,讓大家可以學到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。