Можно ли перечитать сообщение в Kafka

Да, можно. В Kafka сообщения хранятся в топиках, разделённых на партиции, и сохраняются в течение заданного времени (по умолчанию 7 дней) или до достижения лимита размера. Потребитель может перечитать сообщения, управляя своим offset — указателем на текущую позицию в партиции.

Пример сдвига offset для перечитывания:

consumer.seek(partition, desiredOffset); // Устанавливаем offset вручную

Важно:

• Для этого нужно знать желаемый offset или использовать beginningOffsets()/endOffsets().
• Автоматический сброс offset (например, через auto.offset.reset=earliest) работает только при первом подключении группы.
• Перечитывание возможно, если сообщения ещё не удалены по retention policy.

Для постоянного перечитывания можно создать новую consumer group или использовать assign() вместо subscribe().