第1个回答 2017-03-11
很早以前我们组里的Intern写过一个Patch用来GC旧的consumer metadata from ZK：
[KAFKA-559] Garbage collect old consumer metadata entries
这个最终没有merge进code base，不过你可以考虑拿过来改一改自己用。
此外就是新版本0.9里面新增的Java New Consumer API，去掉了ZK的依赖，直接用Kafka Server做Coordination，在这里只要一个consumer group里面所有的member都掉线后，这个group之后就会被自动GC掉，包括它的offsets等等。这个新版本Consumer已经用在LI快两年了。当然要用这个新client你也需要upgrade你的Kafka Server到0.9版本：
Consumer Client Re-Design本回答被网友采纳
[KAFKA-559] Garbage collect old consumer metadata entries
这个最终没有merge进code base，不过你可以考虑拿过来改一改自己用。
此外就是新版本0.9里面新增的Java New Consumer API，去掉了ZK的依赖，直接用Kafka Server做Coordination，在这里只要一个consumer group里面所有的member都掉线后，这个group之后就会被自动GC掉，包括它的offsets等等。这个新版本Consumer已经用在LI快两年了。当然要用这个新client你也需要upgrade你的Kafka Server到0.9版本：
Consumer Client Re-Design本回答被网友采纳
相似回答
