kafka的group怎么能接着消费

如题所述

很早以前我们组里的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

温馨提示：内容为网友见解，仅供参考

当前网址：https://22.t2y.org/zz/x2f0scctxh0tifhxs2.html