Skip to content

Commit 629a07e

Browse files
committed
GH-1825: Fix Missing Nullable Annotation
Resolves #1825
1 parent 98c1640 commit 629a07e

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
import org.springframework.kafka.listener.AbstractMessageListenerContainer;
4242
import org.springframework.kafka.listener.ListenerContainerRegistry;
4343
import org.springframework.kafka.listener.MessageListenerContainer;
44+
import org.springframework.lang.Nullable;
4445
import org.springframework.util.Assert;
4546
import org.springframework.util.StringUtils;
4647

@@ -98,6 +99,7 @@ public void setApplicationContext(ApplicationContext applicationContext) throws
9899
* @see #getListenerContainerIds()
99100
*/
100101
@Override
102+
@Nullable
101103
public MessageListenerContainer getListenerContainer(String id) {
102104
Assert.hasText(id, "Container identifier must not be empty");
103105
return this.listenerContainers.get(id);

spring-kafka/src/main/java/org/springframework/kafka/listener/ListenerContainerRegistry.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919
import java.util.Collection;
2020
import java.util.Set;
2121

22+
import org.springframework.lang.Nullable;
23+
2224
/**
2325
* A registry for listener containers.
2426
*
@@ -36,6 +38,7 @@ public interface ListenerContainerRegistry {
3638
* @see org.springframework.kafka.config.KafkaListenerEndpoint#getId()
3739
* @see #getListenerContainerIds()
3840
*/
41+
@Nullable
3942
MessageListenerContainer getListenerContainer(String id);
4043

4144
/**

0 commit comments

Comments
 (0)