0

私は、Spring Boot バージョン 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()ですか?

前もって感謝します！

4

1 に答える 1

0

kstreams で REPLACE_THREAD をサポートするには、Springboot のバージョンが 2.6 以上である必要があります。 https://spring.io/projects/spring-kafka#:~:text=Spring%20Boot%202.4%20users%20should,will%20use%20the%20correct%20version )。

于 2021-08-16T07:45:16.927 に答える