我在用 Confluent / Apache Kafka 0.10
使用压缩主题作为分布式缓存同步机制。当应用程序启动时,它会生成一个特定于示例的 consumer group id
. 当添加和删除示例以实现水平可伸缩性时,显然我们得到了大量的组id,这些id永远不会被再次使用。
我相信这是一个完美的用例 KStreams
以及 KTables
,但我尝试自己做这件事是出于理智的原因,也是因为 KStreams
以及 KTables
在0.10中定义为α质量。
有什么问题吗 Kafka API
我可以使用的调用可以删除现有的 consumer group
,知道它不应该再被使用?
自 Zookeeper
没有维持消费补偿 version 0.10
,有没有办法删除 consumer group
使用 Kafka
?
2条答案
按热度按时间pcww981p1#
自kafka0.9以来,使用了一个内部主题来存储提交的偏移量。您可以通过配置这些偏移应保持多长时间
offsets.retention.minutes
. (另请参见offsets.retention.check.interval.ms
).f45qwnt82#
Kafka的cli是可能的