kafka 流可以重启崩溃的流线程吗？
Can kafka streams restart crashed stream threads?
我在文档中找不到任何关于此的内容。假设您有 props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
并且流任务因未捕获的异常而崩溃。
你能以某种方式强制重启吗？根据我的实验，崩溃的处理器线程不会重新启动。
目前无法在不重新启动客户端的情况下执行此操作。将在 2.8 版中引入关闭崩溃线程和创建替换线程以及改进异常处理的能力。
我在文档中找不到任何关于此的内容。假设您有 props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, 2);
并且流任务因未捕获的异常而崩溃。
你能以某种方式强制重启吗？根据我的实验，崩溃的处理器线程不会重新启动。
目前无法在不重新启动客户端的情况下执行此操作。将在 2.8 版中引入关闭崩溃线程和创建替换线程以及改进异常处理的能力。