卡夫卡组清理

Question

我正在使用 kafka（v.0.10.1.1）和一些动态组（为每个新消费者创建新的 group.id）。我必须重新检查/过滤过去的事件流以获得某些标准，这意味着一段时间后我有很多组。是否会自动清理旧的未使用的组？

Answer 1

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