apache-kafka - kafka 流可以重新启动崩溃的流线程吗？

我在文档中找不到任何关于此的内容。考虑一下您有 props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
一个流任务崩溃并出现未捕获的异常。
你能以某种方式强制重启吗？根据我的实验，崩溃的处理器线程不会重新启动。

标签： apache-kafkaapache-kafka-streams

如果不重新启动客户端，目前无法做到这一点。关闭崩溃线程和创建替换以及改进的异常处理的能力将在 2.8 版中引入。