spring 版本 2.6.7 不支持 KStream 中的 REPLACE THREAD 选项
spring version 2.6.7 doesn't support REPLACE THREAD option in KStream
我使用 spring 引导版本 2.5.3，spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我想对 kafka 流中的未捕获异常处理程序使用 REPLACE_THREAD 选项。
但我无法使用它，因为 StreamsBuilderFactoryBeanConfigurer（2.6.7 版本）不支持
fb.setUncaughtExceptionHandler(ex -> { log.error("Uncaught exception: ", e); snsService.publish("UncaughtException thrown"); return StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse.REPLACE_THREAD; });
是否可以用 fb.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() 替换流线程？
提前致谢！
Springboot 版本应大于 2.6 以支持 kstreams 中的 REPLACE_THREAD。
https://spring.io/projects/spring-kafka#:~:text=Spring%20Boot%202.4%20users%20should,will%20use%20the%20correct%20version).
我使用 spring 引导版本 2.5.3，spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我想对 kafka 流中的未捕获异常处理程序使用 REPLACE_THREAD 选项。
但我无法使用它，因为 StreamsBuilderFactoryBeanConfigurer（2.6.7 版本）不支持
fb.setUncaughtExceptionHandler(ex -> { log.error("Uncaught exception: ", e); snsService.publish("UncaughtException thrown"); return StreamsUncaughtExceptionHandler.StreamThreadExceptionResponse.REPLACE_THREAD; });
是否可以用 fb.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() 替换流线程？
提前致谢！
Springboot 版本应大于 2.6 以支持 kstreams 中的 REPLACE_THREAD。 https://spring.io/projects/spring-kafka#:~:text=Spring%20Boot%202.4%20users%20should,will%20use%20the%20correct%20version).