很早以前我们组里的Intern写过一个Patch用来GC旧的consumer metadata from ZK：

这个最终没有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版本：