Java创建kafka消费者,不消费报Marking the coordinator servername93:8082 (id: 2147483554 rack: null) dead for group notice-topic_consumer2

伴我同行 发表于: 2019-10-10   最后更新时间: 2021-10-19 10:51:16   5,494 游览

kafka Java创建消费者 继上次内外网无法连接之后又出现新的问题

修改了本地与服务器上的host文件之后可以链接上了,但是一直报也不消费,网上找了很久也没找到相似的问题,希望大佬有时间的话帮我看看

2019-10-10 09:39:00,719 [pool-1-thread-1] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group notice-topic_consumer2
2019-10-10 09:39:02,150 [pool-1-thread-1] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group notice-topic_consumer2 with generation 2
2019-10-10 09:39:02,152 [pool-1-thread-1] INFO  org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [old_train_hours_sfm-0, old_train_hours_sfm-3, old_train_hours_sfm-1, old_train_hours_sfm-2] for group notice-topic_consumer2
2019-10-10 09:39:19,871 [kafka-coordinator-heartbeat-thread | notice-topic_consumer2] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator servername93:8082 (id: 2147483554 rack: null) dead for group notice-topic_consumer2
2019-10-10 09:40:10,627 [kafka-coordinator-heartbeat-thread | notice-topic_consumer2] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator servername93:8082 (id: 2147483554 rack: null) for group notice-topic_consumer2.
2019-10-10 09:40:34,665 [kafka-coordinator-heartbeat-thread | notice-topic_consumer2] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator servername93:8082 (id: 2147483554 rack: null) dead for group notice-topic_consumer2
发表于 2019-10-10
添加评论

内外网:https://www.orchome.com/1903
是info日志,反复的刷,版本问题,客户端和kafka的版本要对应。

另外,跟本次问题没关,推荐zk版本3.4.9。

伴我同行 -> 半兽人 5年前

客户端和服务端都是一致的都是0.11.0.2

半兽人 -> 伴我同行 5年前

升级kafka版本,0.11.0系列有这个bug

伴我同行 -> 半兽人 5年前

我现在的kafka都是正常在运行的能升级么?

半兽人 -> 伴我同行 5年前

可以的,在本地环境可以先演练。
https://www.orchome.com/505

我的方法是修改server.properties中的listeners=PLAINTEXT://IP地址:9092

你的答案

查看kafka相关的其他问题或提一个您自己的问题