无法启动卡夫卡

Question

当启动 kafka-consumer zookeeper 时显示：

[2019-01-02 16:34:15,893] INFO Accepted socket connection from /127.0.0.1:51155 (org.apache.zookeeper.server.NIOServerCnxnFactory)
[2019-01-02 16:34:15,893] WARN Exception causing close of session 0x0: null (org.apache.zookeeper.server.NIOServerCnxn)
[2019-01-02 16:34:15,893] INFO Closed socket connection for client /127.0.0.1:51155 (no session established for client) (org.apache.zookeeper.server.NIOServerCnxn)

这是怎么回事，如何解决？

这是我的全部步骤：

wget http://mirror.bit.edu.cn/apache/kafka/2.1.0/kafka_2.12-2.1.0.tgz
tar zxf kafka_2.12-2.1.0.tgz

cat config/zookeeper.properties | grep -Ev '^$|^#' >> config/zk.properties
cat config/server.properties | grep -Ev '^$|^#' >> config/kfk1.properties

bin/zookeeper-server-start.sh config/zk.properties
bin/kafka-server-start.sh config/kfk1.properties

bin/kafka-topics.sh --create --topic maoge --replication-factor 1 --partitions 1 --zookeeper localhost:2181
bin/kafka-console-consumer.sh --bootstrap-server localhost:2181 --topic maoge --from-beginning

Answer 1

您在控制台消费者中使用 zookeeper 引用（端口 2181），bootstrap-server 这是不正确的。 Kafka consumer 曾经有 --zookeeper 选项，但很久以前就不再使用该配置，现在指的是 broker for consumer。

正确的命令应该是这样的：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic maoge --from-beginning

无法启动卡夫卡

Cannot start Kafka

apache-kafka

apache-zookeeper