Skip to content

Commit 3020619

Browse files
sobychackogaryrussell
authored andcommitted
Add getter for StreamsUncaughtExceptionHandler (#2144)
* Add getter for StreamsUncaughtExceptionHandler StreamsBuilderFactoryBean needs a getter for StreamsUncaughtExceptionHandler. * Addressing PR review
1 parent b09619b commit 3020619

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/StreamsBuilderFactoryBean.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,15 @@ public void setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler s
212212
this.streamsUncaughtExceptionHandler = streamsUncaughtExceptionHandler; // NOSONAR (sync)
213213
}
214214

215+
/**
216+
* Retrieves the current {@link StreamsUncaughtExceptionHandler} set on this factory bean.
217+
* @return {@link StreamsUncaughtExceptionHandler}
218+
* @since 2.8.4
219+
*/
220+
public StreamsUncaughtExceptionHandler getStreamsUncaughtExceptionHandler() {
221+
return this.streamsUncaughtExceptionHandler;
222+
}
223+
215224
public void setStateRestoreListener(StateRestoreListener stateRestoreListener) {
216225
this.stateRestoreListener = stateRestoreListener; // NOSONAR (sync)
217226
}

0 commit comments

Comments
 (0)