We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 009abbb commit 2e23b1bCopy full SHA for 2e23b1b
spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java
@@ -199,6 +199,15 @@ public void setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler s
199
this.streamsUncaughtExceptionHandler = streamsUncaughtExceptionHandler; // NOSONAR (sync)
200
}
201
202
+ /**
203
+ * Retrieves the current {@link StreamsUncaughtExceptionHandler} set on this factory bean.
204
+ * @return {@link StreamsUncaughtExceptionHandler}
205
+ * @since 2.8.4
206
+ */
207
+ public StreamsUncaughtExceptionHandler getStreamsUncaughtExceptionHandler() {
208
+ return this.streamsUncaughtExceptionHandler;
209
+ }
210
+
211
public void setStateRestoreListener(StateRestoreListener stateRestoreListener) {
212
this.stateRestoreListener = stateRestoreListener; // NOSONAR (sync)
213
0 commit comments