Не могу сбросить тему кафки в группе на 1

Question

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

➜  local-kafka_2.12-2.0.0 bin/kafka-consumer-groups.sh --bootstrap-server myserver:1025 --group mygroup --topic mytopic --reset-offsets --to-offset 1 --dry-run
[2019-01-31 21:41:35,664] WARN New offset (1) is lower than earliest offset for topic partition mytopic-0. Value will be set to 121 (kafka.admin.ConsumerGroupCommand$)

TOPIC                          PARTITION  NEW-OFFSET
mytopic                      0          121

При попытке попробовать разные разделы я получаю одно и то же сообщение:

➜  local-kafka_2.12-2.0.0 bin/kafka-consumer-groups.sh --bootstrap-server myserver:1025 --group mygroup --topic mytopic:0,1,2 --reset-offsets --to-offset 1 --dry-run
[2019-01-31 21:43:16,526] WARN New offset (1) is lower than earliest offset for topic partition mytopic-0. Value will be set to 121 (kafka.admin.ConsumerGroupCommand$)
[2019-01-31 21:43:16,528] WARN New offset (1) is higher than latest offset for topic partition mytopic-1. Value will be set to 0 (kafka.admin.ConsumerGroupCommand$)
[2019-01-31 21:43:16,528] WARN New offset (1) is higher than latest offset for topic partition mytopic-2. Value will be set to 0 (kafka.admin.ConsumerGroupCommand$)

TOPIC                      PARTITION  NEW-OFFSET
mytopic                      0          121
mytopic                      1          0
mytopic                      2          0

Можно ли установить смещение на 1?или еще лучше, почему я не могу сбросить тему кафки на 1?

Answer 1

Новое смещение (1) больше, чем последнее смещение для тематического раздела mytopic-2.Значение будет установлено на 0

Это означает, что конечное смещение для mytopic-2 равно нулю, в основном из-за того, что в этом разделе нет записей, поэтому вы не можетеустановить смещение больше нуля.

Новое смещение (1) меньше, чем самое раннее смещение для тематического раздела mytopic-0.Значение будет установлено на 121

Это означает, что начальное смещение для mytopic-0 равно 121, что является самым ранним смещением, которое может быть выставлено клиенту, поэтому вы не можете установитьнижнее смещение для этого раздела.Возможные ситуации, когда начальное смещение будет обновлено, включает: 1. сохранение журнала;Усечение 2.log;3. выдача скрипта kafka-delete-records или DeleteRecordsRequest.