草庐IT

ConsumerCoordinator

全部标签

java - 为组 xxx 提交偏移量时发生错误 UNKNOWN_MEMBER_ID

使用Kafka客户端Java库,消费日志已经工作了一段时间,但由于以下错误,它不再工作了:2016-07-1519:37:54.609INFO4342---[main]o.a.k.c.c.internals.AbstractCoordinator:Markingthecoordinator2147483647dead.2016-07-1519:37:54.933ERROR4342---[main]o.a.k.c.c.internals.ConsumerCoordinator:ErrorUNKNOWN_MEMBER_IDoccurredwhilecommittingoffsetsforg