卡夫卡组清理

Question

我对某些动态组使用kafka（v。0.10.1.1）（为每个新的使用者创建新的group.id）。我必须根据一些标准重新检查/过滤过去的事件流，过了一段时间后，我有很多组。是否有自动清理旧的未使用的组？

Answer 1

由于Kafka自动为您提供帮助，因此无需手动清理未使用的用户组。所有元数据将在组中的最后一位消费者退出后被删除，并且在offsets.retention.minutes时间过后，偏移量也将被删除。