我面临的问题是，我的Kafka流（1线程）意外下降，由于一些错误。我想做的是，如果kafka stream consumer中有一个错误，那么它将被识别，并且流将通过cron自动重新启动，这样就消除了不断监视它的痛苦。有什么合适的方法吗？
到目前为止，我一直在尝试使用 stream.start() 在同一个流示例上得到了错误，但它不工作。