我有一个 Runnable 是Kafka的消费者。我正在我的应用程序中运行这个消费者的n个示例。
当前，如果使用者中存在错误（异常），它只会记录错误并停止工作。在本例中，我有n-1个消费者在运行。
有没有办法自动启动一个新的consumer示例并运行它，这样我就可以再次拥有n个consumer？
我想要实现的逻辑与supervisord相同，它跟踪进程并在需要时重新启动它们。不过，我宁愿有一些标准的解决方案，而不是写我自己的。
我的 Runnable 现在的管理是这样的：

ExecutorService executor = Executors.newFixedThreadPool(2);
executor.execute(consumerInstance1);
executor.execute(consumerInstance2);