Kafka Ktable коррумпированная обработка сообщений

Question

Мы используем Ktabke для агрегирования в kafka, его очень простое использование и ссылаемся на kafka doc.

Я просто пытаюсь выяснить, что если какое-то потребление сообщений завершается неудачно, при агрегировании, как мы можем переместить такое сообщение в тему ошибки или dlq.

Я нашел нечто подобное для KStream, но не смог найти для KTable, и я не смог просто расширить решение KStream до ktable.

Справочник по KStream Обработка плохих сообщений с использованием Kafka Streams API

Мой вариант использования очень прост для любого исключения: просто перейдите к теме ошибки и перейдите к другому сообщению

Answer 1

Нет встроенной поддержки для того, что вы спрашиваете atm (Kafka 2.2), но вам нужно убедиться, что код вашего приложения не выдает никаких исключений. Все предоставляемые обработчики, которые можно настроить, предназначены для исключений, генерируемых средой выполнения Kafka Streams. Эти обработчики предоставляют, потому что в противном случае пользователь вообще не имеет возможности среагировать на это исключение.

Не стесняйтесь создавать запрос функции Jira.