客户端连接不上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 "$@" > "$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 "$@"
fi