如何在未捕获的异常处理程序中重新启动 kafka 流应用程序?

Question

我想在未捕获的异常处理程序中捕获异常后重新启动我的 kafka 流应用程序。该怎么做？

Answer 1

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

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

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