diff --git a/build.gradle b/build.gradle index 06e9b24f40..b83573f9c7 100644 --- a/build.gradle +++ b/build.gradle @@ -21,7 +21,7 @@ plugins { id 'io.spring.nohttp' version '0.0.11' id 'io.spring.dependency-management' version '1.1.7' apply false id 'io.freefair.aggregate-javadoc' version '8.11' - id 'io.spring.nullability' version '0.0.5' apply false + id 'io.spring.nullability' version '0.0.6' apply false } apply plugin: 'io.spring.nohttp' diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java index 66bf4bc67b..67549bd5c0 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/AbstractMessageListenerContainer.java @@ -157,7 +157,7 @@ protected AbstractMessageListenerContainer(@Nullable ConsumerFactory) consumerFactory; - @Nullable String @Nullable [] topics = containerProperties.getTopics(); + String @Nullable [] topics = containerProperties.getTopics(); if (topics != null) { this.containerProperties = new ContainerProperties(topics); } @@ -167,7 +167,7 @@ protected AbstractMessageListenerContainer(@Nullable ConsumerFactory) shareConsumerFactory; - @Nullable String @Nullable [] topics = containerProperties.getTopics(); + String @Nullable [] topics = containerProperties.getTopics(); if (topics != null) { this.containerProperties = new ContainerProperties(topics); } @@ -104,7 +104,7 @@ protected AbstractShareKafkaMessageListenerContainer(ShareConsumerFactory @Nullable [] blockingExceptionTypes; + private Class @Nullable [] blockingExceptionTypes; private boolean retainStandardFatal;