File tree Expand file tree Collapse file tree 1 file changed +3
-0
lines changed
spring-kafka/src/main/java/org/springframework/kafka/config Expand file tree Collapse file tree 1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -217,6 +217,7 @@ public void setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler s
217
217
* @return {@link StreamsUncaughtExceptionHandler}
218
218
* @since 2.8.4
219
219
*/
220
+ @ Nullable
220
221
public StreamsUncaughtExceptionHandler getStreamsUncaughtExceptionHandler () {
221
222
return this .streamsUncaughtExceptionHandler ;
222
223
}
@@ -241,6 +242,7 @@ public void setCloseTimeout(int closeTimeout) {
241
242
* @return {@link Topology} object
242
243
* @since 2.4.4
243
244
*/
245
+ @ Nullable
244
246
public Topology getTopology () {
245
247
return this .topology ;
246
248
}
@@ -274,6 +276,7 @@ public void setCleanupConfig(CleanupConfig cleanupConfig) {
274
276
* may be null if this {@link StreamsBuilderFactoryBean} hasn't been started.
275
277
* @since 1.1.4
276
278
*/
279
+ @ Nullable
277
280
public synchronized KafkaStreams getKafkaStreams () {
278
281
return this .kafkaStreams ;
279
282
}
You can’t perform that action at this time.
0 commit comments