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
内外网:https://www.orchome.com/1903
是info日志,反复的刷,版本问题,客户端和kafka的版本要对应。
另外,跟本次问题没关,推荐zk版本3.4.9。
客户端和服务端都是一致的都是0.11.0.2
升级kafka版本,0.11.0系列有这个bug
我现在的kafka都是正常在运行的能升级么?
可以的,在本地环境可以先演练。
https://www.orchome.com/505
我的方法是修改server.properties中的listeners=PLAINTEXT://IP地址:9092
你的答案