Как перезапустить приложение kafka Stream в обработчике необработанных исключений? - PullRequest
0 голосов
/ 02 мая 2018

Я хочу перезапустить мое приложение kafka Stream после перехвата исключения в обработчике необработанных исключений. Как это сделать?

1 Ответ

0 голосов
/ 04 мая 2018

Если ваше приложение (или, точнее, экземпляр вашего приложения) достигло UncaughtExceptionHandler в Kafka Streams API, оно прошло точку невозврата - вы не можете перезапустить свое приложение оттуда.

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

Приложения Kafka Streams - это обычные приложения Java / Scala, что означает, что они работают как процессы JVM. Вы можете использовать любой инструмент, способный управлять такими процессами, чтобы поддерживать их в рабочем состоянии, перезапускать в случае сбоя и т. Д. В настоящее время популярным примером являются Kubernetes, но также работают и более старые технологии, такие как supervisord. .

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...