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