最近在伺服器上部署kafka,但是在啟動時一直報錯,而本地卻是好好的.究其原因居然是伺服器記憶體太小,剛好小於1G,畢竟用的伺服器配置確實比較垃圾

說回正題,啟動kafka記憶體配置不能少於1G,修改之後,好了,啟動起來了.問題又來了,啟動起來後發現kafka消費者連線不上提供者,總會連線超時.檢查了域名等配置都沒有錯,

1.kafka依賴 : java 環境,以及zookeeper

2.解壓後 啟動 (修改配置後啟動,如果你的zookeeper,kafka消費者提供者都在本機,那麼就不用修改了,看下是否正常啟動即可)

 啟動./

bin/zookeeper-server-start.sh config/zookeeper.properties

啟動./bin/kafka-server-start.sh config/server.properties

配置事項: 

kafka啟動預設記憶體不能少於1G:

     配置檔案 bin/kafka-server-start.sh 找到export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"  1G , 修改為 : KAFKA_HEAP_OPTS="-Xmx512M -Xms512M",以降低記憶體要求

    zookeeper配置: 

配置檔案 config/server.properties 找到 zookeeper.connect=localhost:2181 localhost改成相關域名

    kafka 與提供者與消費者不在同一臺主機的情況: 

配置檔案 config/server.properties  在最後一行新增:advertised.host.name = kafka-provider.com     (kafka-provider為部署kafka所在的伺服器域名)

注意問題：如果釋出成功但訂閱失敗，可進入zookeeper並刪除topic試試：

1.ls /brokers/topics

2.rmr /brokers/topics/(topic name)