Удалить группы потребителей Kafka с подстановочными знаками

Question

У меня есть требование удалить некоторые группы потребителей с определенным суффиксом:

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

Я могу удалить целые темы с помощью шаблона с подстановочными знаками, но не могу удалить потребителягруппирует таким образом.

Есть ли возможность управлять этим?

Answer 1

Инструмент kafka-consumer-groups в настоящее время не позволяет удалять группы с использованием подстановочных знаков.На самом деле он даже не позволяет управлять несколькими группами одновременно, и его необходимо перезапустить для каждой группы.

Идет KIP для добавления поддержки нескольких групп: https://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3A+Multiple+Consumer+Group+Management Я вижу, что кто-то спросило поддержке подстановочных знаков в ветке обсуждения.Не стесняйтесь комментировать там, если вы хотите что-то увидеть, поскольку KIP все еще обсуждается.

В настоящее время единственный вариант - явное удаление каждой группы.Если вы не знаете всех названий групп, вы можете использовать сначала список всех групп и отфильтровать те, которые вас интересуют. Затем удалите их 1 на 1.

Обратите внимание, что AdminClient API позволяет удалить несколько групп одновременно.Хотя это снова, называя их без подстановочных знаков.