卡夫卡消费者健康检查与再造

Question

我们在一个项目中使用Spring客户端。最近，我们注意到，如果卡夫卡消费者因OutOfMemoryError服务而死亡，服务继续正常运行，没有新的消费者被创建。解决这个问题的唯一方法是监视日志中的OOM并手动重新启动服务。我们正在寻找一种使消费者娱乐自动化的方法，例如：

1. 强制Spring (以某种方式)检测已死亡的使用者，并在运行时创建新的使用者。
2. 如果使用者线程中的OOM杀死整个服务，那么AWS自动缩放组可以创建服务的一个新实例。

如有任何建议或想法，敬请见谅。谢谢!

Answer 1

我找到了一个与上面提到的备选方案2有关的解决方案。启动java版本"1.8.0_92“时，有几个JVM选项允许在OOME情况下杀死整个JVM：

 1. -XX:+ExitOnOutOfMemoryError  
 2. -XX:+CrashOnOutOfMemoryError

被添加，请参见发布说明。

当启用此选项时，ExitOnOutOfMemoryError将在第一次出现内存不足错误时退出。如果您希望重新启动JVM的实例，而不是处理内存不足的错误，则可以使用它。 如果启用此选项，当出现内存不足错误时，CrashOnOutOfMemoryError会崩溃并生成文本和二进制崩溃文件。