提问人：Sowmya 提问时间：8/13/2021 更新时间：8/16/2021 访问量：557
spring 版本 2.6.7 不支持 KStream 中的 REPLACE THREAD 选项
spring version 2.6.7 doesn't support REPLACE THREAD option in KStream
问：
我使用 spring boot 版本 2.5.3、spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我想REPLACE_THREAD选项用于 kafka 流中未捕获的异常处理程序。
但是我无法使用它，因为 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()
提前致谢！
答：
0赞
Sowmya
8/16/2021
#1
Springboot 版本应大于 2.6 以支持 kstreams 中的REPLACE_THREAD。https://spring.io/projects/spring-kafka#:~:text=Spring%20Boot%202.4%20users%20should,will%20use%20the%20correct%20version）。
评论