Skip to content

Commit 52d45dc

Browse files
committed
Add Nullable to API methods
Annotate the following methods in StreamsBuilderFactoryBean with Nullable. getStreamsUncaughtExceptionHandler getTopology getKafkaStreams
1 parent c6b2f9c commit 52d45dc

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

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

+3
Original file line numberDiff line numberDiff line change
@@ -204,6 +204,7 @@ public void setStreamsUncaughtExceptionHandler(StreamsUncaughtExceptionHandler s
204204
* @return {@link StreamsUncaughtExceptionHandler}
205205
* @since 2.8.4
206206
*/
207+
@Nullable
207208
public StreamsUncaughtExceptionHandler getStreamsUncaughtExceptionHandler() {
208209
return this.streamsUncaughtExceptionHandler;
209210
}
@@ -228,6 +229,7 @@ public void setCloseTimeout(int closeTimeout) {
228229
* @return {@link Topology} object
229230
* @since 2.4.4
230231
*/
232+
@Nullable
231233
public Topology getTopology() {
232234
return this.topology;
233235
}
@@ -261,6 +263,7 @@ public void setCleanupConfig(CleanupConfig cleanupConfig) {
261263
* may be null if this {@link StreamsBuilderFactoryBean} hasn't been started.
262264
* @since 1.1.4
263265
*/
266+
@Nullable
264267
public synchronized KafkaStreams getKafkaStreams() {
265268
return this.kafkaStreams;
266269
}

0 commit comments

Comments
 (0)