Какие стратегии применяются для обработки ошибок в Kafka Streams binder?

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

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