删除未使用的Kafka消费群

x759pob2  于 2021-06-08  发布在  Kafka
关注(0)|答案(2)|浏览(552)

我在用 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 ?

pcww981p

pcww981p1#

自kafka0.9以来,使用了一个内部主题来存储提交的偏移量。您可以通过配置这些偏移应保持多长时间 offsets.retention.minutes . (另请参见 offsets.retention.check.interval.ms ).

f45qwnt8

f45qwnt82#

Kafka的cli是可能的

./bin/kafka-consumer-groups \
    --bootstrap-server <bootstrap_server(s)> \
    --topic <topic_name> \
    --delete \
    --group <consumer_group_name>
``` `kafka-consumer-groups` 应该可以在Kafka安装之家。

相关问题