java - 如何在未捕获的异常处理程序中重新启动kafka Stream应用程序？

Question

我想在未捕获的异常处理程序中捕获异常后重新启动我的 kafka Stream 应用程序。如何做到这一点？

Answer 1

如果您的应用程序(或者更准确地说，您的应用程序的实例)达到 UncaughtExceptionHandler在 Kafka 的 Streams API 中，它已经过了不归路——您无法从那里重新启动应用程序。

UEH 旨在帮助您正常关闭应用程序实例，例如通过编写信息丰富的日志消息、向您的监控设置发送指标等等。

Kafka Streams 应用程序是普通的 Java/Scala 应用程序，这意味着它们作为 JVM 进程运行。您可以使用任何能够管理此类进程的工具来保持它们的启动和运行，在发生故障时重新启动它们等。当今流行的例子是 Kubernetes，但也有更多的老式技术，例如 supervisord工作顺利。