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 2e594db9..b31a1844 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 @@ -376,7 +376,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 bc6fb4bf..40815e20 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 @@ -54,6 +54,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()); } }