Некоторые стратегии обработки ошибок в Kafka Streams binder:

• LogAndFailExceptionHandler. 15 По умолчанию при возникновении исключения во время десериализации происходит логирование ошибки и сбой приложения. 1
• LogAndContinueExceptionHandler. 15 Позволяет логировать ошибку, пропускать запись и продолжать работу приложения. 1
• Отправка ошибок в очередь недоставленных сообщений (DLQ). 15 Для этого есть настраиваемый обработчик, который позволяет отправлять записи с ошибками десериализации в специальную DLQ. 1
• StreamsUncaughtExceptionHandler. 3 Работает для исключений, которые не обрабатываются Kafka Streams. 3 На этапе обработки может возникать множество ошибок, например, ошибки приложения, временные проблемы с сетью, ошибки, связанные с базой данных. 3
• Замена потока потока. 3 Это тип механизма повторной попытки для временных ошибок. 3 Kafka Streams убивает текущий поток потока и создаёт новый, который снова потребляет записи из последнего зафиксированного смещения. 3
• Остановка отдельного экземпляра потока. 3 Это останавливает отдельный поток потребителя приложения Kafka Streams, который столкнулся с исключением. 3