#exception #apache-kafka #apache-kafka-streams
#исключение #apache-kafka #apache-kafka-streams
Вопрос:
Как описано в разделе, как я могу просто зафиксировать это смещение и продолжить обработку, не выключая потоковое приложение?
Комментарии:
1. Вы пробовали искать обработчик исключений «войти и продолжить»?
2. Это не работает! Такой обработчик для ser и deser, а не для исключений, создаваемых процессором
3. Тогда какое исключение вы получаете? Можете ли вы показать трассировку стека?
4. каждое исключение, не обработанное в процессоре
5. Это несколько расплывчато, но если вы получите неверное сообщение, то оно будет обработано сериализатором. Если вы столкнетесь с исключением во время выполнения в контексте процессора, оно будет обработано обычным перехватом try. Если вы в конечном итоге столкнетесь с любым другим неперехваченным исключением (например, npe), да, приложение с аварийным завершением, независимо от того, является ли оно приложением kstreams или нет