You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
It is not possible to use KafkaStreams#setUncaughtExceptionHandler on the injected KafkaStreams instance because it is already started by the KafkaStreamsProducer managed by kafka-streams Quarkus extension.
Expected behavior
The kafka-streams extension calls setUncaughtExceptionHandler with an instance of StreamsUncaughtExceptionHandler discovered in the application the before the start, much like StateListener and StateRestoreListener
@ozangunalp sorry for the wait, I could only work on this today. I openned #18379 for it.
How do you recommend testing this? I notice that are no tests for the other listernes, since KafkaStreams doesn't allows inspecting the stream object after you configure it. A full blown integration test using TopologyTestDriver might work, but will add considerable complexity.
Describe the bug
It is not possible to use KafkaStreams#setUncaughtExceptionHandler on the injected
KafkaStreams
instance because it is already started by theKafkaStreamsProducer
managed by kafka-streams Quarkus extension.Expected behavior
The kafka-streams extension calls setUncaughtExceptionHandler with an instance of
StreamsUncaughtExceptionHandler
discovered in the application the before the start, much like StateListener and StateRestoreListenerReported by @andrerigon
The text was updated successfully, but these errors were encountered: