apache-kafka - 使用通配符删除 Kafka 消费者组
问题描述
我需要删除一些具有特定后缀的消费者组:
consumer_1_123
consumer_2_123
consumer_3_123
consumer_1_124
consumer_2_124
命令:
./kafka-consumer-groups.sh --bootstrap-server MY_BOOTSTRAP_SERVER --delete --group *_123
失败:
错误:删除某些消费者组失败:* 组“*_123”无法删除,原因是:GROUP_ID_NOT_FOUND
我可以通过通配符模式删除整个主题,但我无法通过这种方式删除消费者组。
有没有可能管理这个?
解决方案
该kafka-consumer-groups
工具目前不允许使用通配符删除组。它实际上甚至不允许一次管理多个组,并且需要为每个组重新启动。
正在进行一个 KIP 以添加对多个组的支持:https ://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3A+Multiple+Consumer+Group+Management 我看到有人询问通配符支持讨论线程。如果您希望看到 KIP 仍在讨论中,请随时在此处发表评论。
目前唯一的选择是明确删除每个组。如果您不知道所有组名,可以先列出所有组并过滤您感兴趣的组。然后将它们一一删除。
请注意,AdminClient API允许一次删除多个组。尽管它再次通过不带通配符的方式命名它们。
推荐阅读
- java - 构建失败并出现异常:在根项目中找不到任务“-”
- rust - 使用 AsyncRead 引用字节数组时,为什么会出现“找不到名为 `read` 的方法”?
- azure - 我们可以模拟 TFX 命令(azure devops)的执行吗?参数-Whatif(powershell)之类的东西
- .net - EF Core 3.1 中的 Include / ThenInclude 将如何转换为 Inner Join
- c# - 在 T4 模板中使用 .NET Core 程序集
- swift - HTTP Live 流在 AVPlayer Swift 中不可读且不起作用
- r - 如何使函数在R中的矩阵中对某些值进行排序?
- google-apps-script - 使用谷歌表格的应用脚本替换文本
- java - 空值检查的常用方法
- php - 如何使用 Sales Force phptoolkit 在 Order 对象上提供 PriceBook2Id?