创建消费者后未建立Kafka zookeper会话
这是我第一次使用Kafka。我遵循了本教程。启动Zookeper后，我启动了kafka服务器。接下来创建了一个主题，然后启动了该主题的消费者。这是当Zookeper日志说
导致会话0x0关闭的异常：null
2019-01-04 14:11:58,160 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50480 (no session established for client)
2019-01-04 14:11:59,073 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:50481
2019-01-04 14:11:59,074 [myid:] - WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
2019-01-04 14:11:59,078 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@1040] - Closed socket connection for client /127.0.0.1:50481 (no session established for client)
2019-01-04 14:11:59,994 [myid:] - INFO [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxnFactory@215] - Accepted socket connection from /127.0.0.1:50482
2019-01-04 14:11:59,995 [myid:] - WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@383] - Exception causing close of session 0x0: null
我正在使用Windows 10。
kafka_2.11-2.1.0
zookeeper-3.4.12
共有2个答案
我清除了
/tmp/zookeeper
/tmp/kafka-logs/
杀死所有kafka进程。
然后它成功了！
@itssajan
我尝试了类似的教程，因为你在你的部分发布https://dzone.com/articles/running-apache-kafka-on-windows-os，有一个错误在那个博客-.
我试图将zookeeper更改为具有localhost 9092的引导服务器，它对我有用。
试试这个，应该能在windows下工作。
c:\ dev \ Kafka _ 2.12-2 . 2 . 1 \ Kafka _ 2.12-2 . 2 . 1 \ bin \ windows
-
假设我有一个服务，它通过kafka-rest-proxy来消费消息，并且总是在同一个消费者组上。我们还可以说，它正在消耗一个有一个分区的主题。当服务启动时，它在kafka-rest-proxy中创建一个新的使用者，并使用生成的使用者url，直到服务关闭。当服务重新启动时，它将在kafka-rest-proxy中创建一个新的消费者，并使用新的url（和新的消费者）进行消费。 > 因为kafka每个分
-
我是Kafka的新手，我想验证我的设计。下面是我所拥有的。 我有一个生产者发布到一个主题，有一堆容器（部署我的web应用程序的地方），每个容器上都运行着一个消费者。这些消费者不在消费者组中，也不独立地消费消息。每个消费者都应该阅读主题中的所有消息。例如，假设主题m0,m1,m2上有3条消息，那么consumer1到consumerN应该独立地读取m0,m1,m2。每个使用者在处理读取的消息后立即提
-
当我向主题“Test19”发送任何消息时，配置的ServiceActivator“ProcessMessage”方法将两条消息显示为配置的两个客户，但这里的问题是，在添加到消费者上下文之前，我需要为每个客户加载入站配置文件…否则，我只能在控制台中得到一条消息…是正确的方式还是我需要在这里改变什么？ 谢了。
-
那么我如何确保我的队列中只有一个消费者呢？
-
是否有一种方法以编程方式访问和打印使用者滞后偏移，或者说使用者读取的最后一条记录的偏移与某个生产者写入该使用者分区的最后一条记录的偏移之间的位置差。 要知道我的最终目标是将这个值发送到prometheus进行监视，我应该在上面添加哪些语句来得到滞后偏移值？
-
我经常看到kafka消费者的当前偏移和滞后设置为未知的问题 早期消费者的偏移和滞后 几天后，当我再次订阅该消费者时，其偏移和滞后被设置为未知 kafka是否删除了该消费者之前的偏移，因为我正在取消订阅整个消费群的主题？