diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/BatchMessagingMessageListenerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/BatchMessagingMessageListenerAdapter.java
index abc65aef96..a90d5831c9 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/BatchMessagingMessageListenerAdapter.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/BatchMessagingMessageListenerAdapter.java
@@ -69,7 +69,7 @@ public class BatchMessagingMessageListenerAdapter<K, V> extends MessagingMessage
 	 * @param bean the listener bean.
 	 * @param method the listener method.
 	 */
-	public BatchMessagingMessageListenerAdapter(Object bean, Method method) {
+	public BatchMessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method) {
 		this(bean, method, null);
 	}
 
@@ -79,7 +79,7 @@ public BatchMessagingMessageListenerAdapter(Object bean, Method method) {
 	 * @param method the listener method.
 	 * @param errorHandler the error handler.
 	 */
-	public BatchMessagingMessageListenerAdapter(Object bean, Method method,
+	public BatchMessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method,
 			@Nullable KafkaListenerErrorHandler errorHandler) {
 
 		super(bean, method, errorHandler);
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
index 26d084a853..6f7fb549dc 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/MessagingMessageListenerAdapter.java
@@ -111,7 +111,7 @@ public abstract class MessagingMessageListenerAdapter<K, V> implements ConsumerS
 	private static final boolean monoPresent =
 			ClassUtils.isPresent("reactor.core.publisher.Mono", MessageListener.class.getClassLoader());
 
-	private final Object bean;
+	private final @Nullable Object bean;
 
 	protected final LogAccessor logger = new LogAccessor(LogFactory.getLog(getClass())); //NOSONAR
 
@@ -166,7 +166,7 @@ public abstract class MessagingMessageListenerAdapter<K, V> implements ConsumerS
 	 * @param bean the bean.
 	 * @param method the method.
 	 */
-	protected MessagingMessageListenerAdapter(Object bean, Method method) {
+	protected MessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method) {
 		this(bean, method, null);
 	}
 
@@ -177,7 +177,8 @@ protected MessagingMessageListenerAdapter(Object bean, Method method) {
 	 * @param errorHandler the kafka listener error handler.
 	 */
 	@SuppressWarnings("this-escape")
-	protected MessagingMessageListenerAdapter(Object bean, Method method, @Nullable KafkaListenerErrorHandler errorHandler) {
+	protected MessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method,
+			@Nullable KafkaListenerErrorHandler errorHandler) {
 		this.bean = bean;
 		this.inferredType = determineInferredType(method); // NOSONAR = intentionally not final
 		this.errorHandler = errorHandler;
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
index 4427f93d16..fbacd301ae 100644
--- a/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
+++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/adapter/RecordMessagingMessageListenerAdapter.java
@@ -50,11 +50,11 @@
 public class RecordMessagingMessageListenerAdapter<K, V> extends MessagingMessageListenerAdapter<K, V>
 		implements AcknowledgingConsumerAwareMessageListener<K, V> {
 
-	public RecordMessagingMessageListenerAdapter(Object bean, Method method) {
+	public RecordMessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method) {
 		this(bean, method, null);
 	}
 
-	public RecordMessagingMessageListenerAdapter(Object bean, Method method,
+	public RecordMessagingMessageListenerAdapter(@Nullable Object bean, @Nullable Method method,
 			@Nullable KafkaListenerErrorHandler errorHandler) {
 
 		super(bean, method, errorHandler);