我的一个服务几个小时前就停止了。我重新启动了服务器，但这个消费进程只是没有注册Kafka。这就是消费者启动时显示的内容：
2017-04-21 10:22:54.887 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.ConsumerCoordinator : Revoking previously assigned partitions [] for group mysql-conversions-group
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked:[]
2017-04-21 10:22:54.890 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : (Re-)joining group mysql-conversions-group
2017-04-21 10:22:54.915 INFO 18036 --- [afka-consumer-1] o.a.k.c.c.internals.AbstractCoordinator : Marking the coordinator li819-138.members.linode.com:9092 (id: 2147483646 rack: null) dead for group mysql-conversions-group我有4个不同的消费群体，他们运行得很好。有什么想法吗？
更新
真奇怪。我们必须重新启动另一个消费程序，在重新启动之后，另一个前一秒工作正常的消费程序现在正在记录相同的错误。基本上，我们现在有两个消费者进程，由于某种原因无法连接到Kafka。
1条答案
按热度按时间2q5ifsrm1#
回答我自己的问题：
终于成功了。这不是经纪人的问题，也不是消费者的问题。发生的事情是，我们在晚上8:30左右启用了Kafka经纪人的防火墙。已经与Kafka有联系的消费者工作得很好。但是，当其中一个使用者重新启动时，它们无法连接到协调器节点。我们在两个kafka代理上都禁用了防火墙，数据立即被转发给消费者。这是一个临时的自动取款机，但至少我们有东西。