客戶端連線不上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