NonNull API Retryable Topic

Author: garyrussell

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/ListenerContainerFactoryConfigurer.java

@@ -35,6 +35,7 @@
 import org.springframework.kafka.listener.MessageListener;
 import org.springframework.kafka.listener.adapter.KafkaBackoffAwareMessageListenerAdapter;
 import org.springframework.kafka.support.TopicPartitionOffset;
+import org.springframework.lang.Nullable;
 import org.springframework.util.Assert;
 import org.springframework.util.backoff.BackOff;
 
@@ -59,9 +60,11 @@
  */
 public class ListenerContainerFactoryConfigurer {
 
-	private BackOff providedBlockingBackOff = null;
+	@Nullable
+	private BackOff providedBlockingBackOff;
 
-	private Class<? extends Exception>[] blockingExceptionTypes = null;
+	@Nullable
+	private Class<? extends Exception>[] blockingExceptionTypes;
 
 	private boolean retainStandardFatal;
 

spring-kafka/src/main/java/org/springframework/kafka/retrytopic/package-info.java

@@ -1,4 +1,6 @@
 /**
  * Package for retryable topic handling.
  */
+@org.springframework.lang.NonNullApi
+@org.springframework.lang.NonNullFields
 package org.springframework.kafka.retrytopic;