Kafka 群组清理

Question

我将 kafka (v. 0.10.1.1) 与一些动态组一起使用（为每个新消费者创建新的 group.id）。对于某些标准，我必须 recheck/filter 过去的事件流，这意味着一段时间后我有很多组。是否有自动清理旧的未使用组？

Answer 1

无需手动清理未使用的消费者组，因为 Kafka 会自动为您清理。一旦组中的最后一个消费者退出，所有元数据将被删除，偏移量也将在 offsets.retention.minutes 时间过去后被删除。