删除未使用的Kafka消费群

x759pob2 于 2021-06-08 发布在 Kafka

关注(0)|答案(2)|浏览(446)

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

apache-kafka apache-kafka-streams kafka-consumer-api confluent-platform

来源：https://stackoverflow.com/questions/38402364/delete-unused-kafka-consumer-group

2条答案

按热度按时间

pcww981p1#

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

赞(0）回复(0）举报 2021-06-09

f45qwnt82#

Kafka的cli是可能的

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

赞(0）回复(0）举报 2021-06-09

我来回答

删除未使用的Kafka消费群

2条答案

相关问题

热门标签

最新问答