класс ошибок KAFKA_DATA_LOSS
Некоторые данные могут быть потеряны, так как они больше не доступны в Kafka; либо данные устарели в Kafka, либо раздел, возможно, был удален до обработки всех данных в этом разделе. Если вы не хотите, чтобы потоковый запрос завершался ошибкой в таких случаях, установите для параметра источника failOnDataLoss значение false. Причина:
ДОБАВЛЕННЫЙ_РАЗДЕЛ_НЕ_НАЧИНАЕТСЯ_С_НУЛЕВОГО_СМЕЩЕНИЯ
Добавленная секция <topicPartition> начинается с <startOffset> вместо 0.
НЕ УДАЛОСЬ ПРОЧИТАТЬ ДИАПАЗОН СМЕЩЕНИЙ
Не удалось считать записи в смещении [<startOffset>, <endOffset>) для раздела <topicPartition>
с группой потребителей <groupId>.
НАЧАЛЬНОЕ_СМЕЩЕНИЕ_НЕ_НАЙДЕНО_ДЛЯ_РАЗДЕЛОВ
Не удается найти начальные смещения для секций <partitions>. Возможно, они были удалены.
РАЗДЕЛЫ_УДАЛЕНЫ
Разделы <partitions> удалены.
РАЗДЕЛЫ УДАЛЕНЫ И ПРИСУТСТВУЕТ ID ГРУППЫ
Разделы <partitions> удалены.
Параметр Kafka 'kafka.<groupIdConfig>' в этом запросе установлено значение.
не рекомендуется задать этот параметр. Этот параметр небезопасно для использования, так как несколько параллельных
запросы или источники, использующие один и тот же идентификатор группы, будут мешать друг другу, так как они являются частью
той же группы потребителей. Перезапущенные запросы также могут подвергаться вмешательству
предыдущий запуск с тем же идентификатором группы. Пользователь должен иметь только один запрос для каждого идентификатора группы.
и/или установите опцию "kafka.session.timeout.ms" на очень маленькое значение, чтобы Kafka
потребители из предыдущего запроса помечаются как мертвые координатором группы Kafka, прежде чем
Перезапущенный запрос начинает выполняться.
СМЕЩЕНИЕ_РАЗДЕЛА_ИЗМЕНЕНО
Смещение <topicPartition> раздела было изменено с <prevOffset> на <newOffset>.
СБРОС НАЧАЛЬНОГО СМЕЩЕНИЯ
Начальное смещение для <topicPartition> было <offset>, но сброс потребителя был до <fetchedOffset>.