java中自动重启Kafka Stream

Question

我面临的问题是我的 Kafka Stream（1 线程）由于某些错误而意外停机。我想要做的是，如果 Kafka 流消费者出现错误，它会被识别并通过 cron 自动重新启动流，从而消除不断监控它的痛苦。有什么合适的方法吗？

到目前为止，我已经尝试在出现错误但不起作用的同一个流实例上使用 stream.start()。

Answer 1

您现在不能重复使用流。然而，在 2.8（几个月后）中，计划允许在处理程序中替换流线程。