diff --git a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java index 1924adb4..3318b55e 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/listener/ContainerProperties.java @@ -543,6 +543,7 @@ public class ContainerProperties extends ConsumerProperties { return this.idlePartitionEventInterval; } + @Nullable public PlatformTransactionManager getTransactionManager() { return this.transactionManager; } @@ -555,7 +556,7 @@ public class ContainerProperties extends ConsumerProperties { * @since 1.3 * @see #setAckMode(AckMode) */ - public void setTransactionManager(PlatformTransactionManager transactionManager) { + public void setTransactionManager(@Nullable PlatformTransactionManager transactionManager) { this.transactionManager = transactionManager; }