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