這篇文章給大家分享的是Linux環(huán)境中安裝配置kafka的詳細(xì)教程,相信大部分人都還不知道怎么安裝,為了讓大家學(xué)會(huì),給大家總結(jié)了以下內(nèi)容,話不多說,一起往下看吧。
網(wǎng)站建設(shè)哪家好,找創(chuàng)新互聯(lián)!專注于網(wǎng)頁(yè)設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、微信平臺(tái)小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項(xiàng)目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了振安免費(fèi)建站歡迎大家使用!
必須安裝zookeeper。Linux安裝zookeeper
kafka官網(wǎng)下載頁(yè)面
# 版本:kafka_2.11-2.3.0.tgz wget http://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.3.0/kafka_2.11-2.3.0.tgz
tar -zxvf kafka_2.11-2.3.0.tgz cp kafka_2.11-2.3.0 /usr/local/kafka
cd /usr/local/kafka/bin # 啟動(dòng)命令:守護(hù)進(jìn)程進(jìn)行啟動(dòng) ./kafka-server-start.sh -daemon ../config/server.properties
備注:這里有可能報(bào)錯(cuò),因?yàn)槟J(rèn)情況下,kafka默認(rèn)的內(nèi)存要1G,如果你這里沒有這么多內(nèi)存可用,那么就會(huì)啟動(dòng)失敗。報(bào)錯(cuò)如下:
Java Hotspot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000000c5330000, 986513408, 0) failed; error='Cannot allocate memory' (errno=12) # # There is insufficient memory for the Java Runtime Environment to continue. # Native memory allocation (malloc) failed to allocate 986513408 bytes for committing reserved memory. # An error report file with more information is saved as: # hs_err_pid5535.log
解決方案:
修改啟動(dòng)腳本:kafka-server-start.sh vim kafka-server-start.sh
設(shè)置內(nèi)容根據(jù)自己情況進(jìn)行設(shè)置。
# 名為test的chart,只有一個(gè)副本,一個(gè)分區(qū) kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic chart # 查看kafka的topic kafka-topics.sh -list -zookeeper localhost:2181
# 啟動(dòng)生產(chǎn)端 ./kafka-console-producer.sh --broker-list localhost:9092 --topic chart #啟動(dòng)消費(fèi)端 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic chart --from-beginning
看完這篇文章,你們學(xué)會(huì)在Linux環(huán)境中安裝配置kafka了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝各位的閱讀。