Подходы к обработке ошибок, упомянутые в документации весеннего облачного потока, не работают с связывателями потока kafka.
Кроме того, явный вызов обработчика DLQ работает только с обработкой нижнего уровня kafka.
ТамПохоже, что ни одна из реализаций обработки ошибок приложения не доступна в DSL-потоках kafka.
Я включил ошибки serde DLQ, и он успешно получает сообщения об ошибках serde.Теперь я хочу отправлять сообщения в этот DLQ, которые приводят к сбоям во время обработки.Один из подходов может состоять в том, чтобы определить DLQ или тему ошибки в качестве одного из пунктов назначения производителя и отправить ошибочные сообщения из блока catch.
Есть ли какой-либо рекомендуемый / опробованный подход для обработки этого сценария?