записей в топике? Получаю такую ошибку:
org.apache.kafka.common.errors.CorruptRecordException: Found record size -793718595 smaller than minimum record overhead (14) in file
и на этом сообщении приложение падает при чтении топика.
Ну, скорее всего убивать реплику и восстанавливать с других, но конкретный порядок действий вряд ли кто-то подскажет.
если еще актуально... Если это битое сообщение вам не нужно, то можно погсаить коньсюмер, руками вычитать битое сообщение, указав ту же группу. Оффсет сдвинется - и после этого включать обратно консьюмер
Обсуждают сегодня