Смещение сброса Kafka 1.0 не сбрасывает все разделы на 0 - PullRequest
0 голосов
/ 27 апреля 2018

При сбросе потребительских смещений kafka до ранних значений некоторые разделы сохраняются со смещением> 0

.

$ kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group group1 --topic topic1 --reset-offsets --to-earliest --execute

Показывает:

TOPIC             PARTITION  NEW-OFFSET
topic1            4          0
topic1            1          6153734
topic1            3          0
topic1            2          0
topic1            0          0

Почему также нет 0 для раздела 1?

1 Ответ

0 голосов
/ 27 апреля 2018

Проблема заключалась в том, что самое раннее смещение имеет значение 6153734

Нашел с помощью --reset-offsets --to-offset 0

что выводит

WARN New offset (0) is lower than earliest offset. Value will be set to 6153734 (kafka.admin.ConsumerGroupCommand$)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...