diff --git a/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java b/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java index 585ebb14..5d4e24d1 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java @@ -401,7 +401,7 @@ public abstract class AbstractKafkaListenerContainerFactory 0, this.containerProperties.getAckCount(), diff --git a/spring-kafka/src/test/java/org/springframework/kafka/annotation/ContainerFactoryTests.java b/spring-kafka/src/test/java/org/springframework/kafka/annotation/ContainerFactoryTests.java index b3b6b815..0c6dc77f 100644 --- a/spring-kafka/src/test/java/org/springframework/kafka/annotation/ContainerFactoryTests.java +++ b/spring-kafka/src/test/java/org/springframework/kafka/annotation/ContainerFactoryTests.java @@ -59,6 +59,9 @@ public class ContainerFactoryTests { assertThat(container.getContainerProperties().getAckCount()).isEqualTo(123); assertThat(KafkaTestUtils.getPropertyValue(container, "concurrency", Integer.class)).isEqualTo(22); assertThat(customized).isTrue(); + ConcurrentMessageListenerContainer container2 = factory.createContainer("foo"); + assertThat(container.getContainerProperties().getKafkaConsumerProperties()) + .isNotSameAs(container2.getContainerProperties().getKafkaConsumerProperties()); } @SuppressWarnings("unchecked")