Кафка: Сброс смещения определенного раздела темы

Question

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

Мне удалось сбросить смещение всех разделов темы, используя приведенную ниже команду, но яхотите сбросить смещение только для определенных разделов.

Команда, которая работала для всех разделов

kafka-consumer-groups.sh -- bootstap-server localhost:1111 -- command-config <file> -- group <group> -- topic <topic> -- reset-offset -- shift-by -1

Приведенная выше команда не принимает разделы и сбрасывается для всех разделов.Как я могу сбросить только определенный раздел.

Answer 1

Чтобы изменить смещение только для определенного раздела, вам необходимо указать флаг --topic, название темы и номер раздела, который вы хотите изменить.

Можно использовать следующую команду:

./bin/kafka-consumer-groups.sh --bootstrap-server localhost:1111 --group grId --topic someTopicName:0 --reset-offsets --shift-by 1 --execute

Резюме из kafka-consumer.groups.sh может помочь вам лучше понять его:

- тема : тема, информацию о группах потребителей которой следует удалить, или тема, чья информация должнабыть включены в процесс сброса смещения.В случае reset-offsets разделы могут быть указаны в следующем формате: topic1:0,1,2, где 0,1,2 - раздел, который будет включен в процесс.Сброс смещения также поддерживает ввод нескольких тем.