客戶端連線不上kafka的問題以及kafka總是自動關閉問題
阿新 • • 發佈:2018-11-15
客戶端連線不上kafka的問題
java使用客戶端測試連線kafka:https://blog.csdn.net/Lnho2015/article/details/51353936
以下問題是基於kafka所在伺服器跟開發環境不在一臺機器上
1.把listeners和advertised.listeners前面的#去掉,並把埠號之前的一串英文改為伺服器的ip地址如:listeners=PLAINTEXT://192.168.3.61:9092
advertised.listeners=PLAINTEXT://192.168.3.61:9092
zookeeper.connect=localhost:2181改為zookeeper.connect=192.168.3.61:2181
2.關掉伺服器的防火牆,我用的centos6.4 命令:service iptables stop
3.使用命令列傳送訊息接收訊息時localhost用ip地址替換
kafka總是自動關閉問題
解決辦法:以守護程序的方式啟動
bin/kafka-server-start.sh -daemon ./config/server.properties
進行啟動,到現在為止 kafka 還在正常執行。和不加 -daemon 區別在於:
bin/kafka-run-class.sh
# Launch mode
if [ "x$DAEMON_MODE" = "xtrue" ]; then
#加 daemon 會使用該命令
nohup $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS " [email protected]" > "$CONSOLE_OUTPUT_FILE" 2>&1 < /dev/null &
else
#不加時使用的命令
exec $JAVA $KAFKA_HEAP_OPTS $KAFKA_JVM_PERFORMANCE_OPTS $KAFKA_GC_LOG_OPTS $KAFKA_JMX_OPTS $KAFKA_LOG4J_OPTS -cp $CLASSPATH $KAFKA_OPTS "[email protected]"
fi