Springboot Cloud Stream Kafka Binder - как обрабатывать исключение DLQ и исключение десериализации?
1) Для потребителя Springboot Cloud Stream Kafka Binder после x повторных попыток сообщение об ошибке отправляется в DLQ. Мой вопрос: если запись в сам DLQ имеет исключение, как мы обычно обрабатываем это исключение? Есть ли у нас механизм для повторной попытки записи в DLQ? В случае сбоя DLQ мы все еще фиксируем смещение исходного сообщения и пропускаем это сообщение?
2) Для потребителя Springboot Cloud Stream Kafka Binder, как мы обрабатываем исключение десериализации, поскольку оно происходит до достижения StreamListener? Я вижу документацию для связывателя потока kafka, но не для связующего устройства kafka.