Skip to content

Commit 110f48f

Browse files
committed
GH-1808: Refine ignored properties
Related to #1808 Turns out we also need to ignore a deprecated `setConsumerProperties` when `BeanUtils.copyProperties()` still sets the value by reflection **Cherry-pick to `2.3.x`**
1 parent 4f68b35 commit 110f48f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/AbstractKafkaListenerContainerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -376,7 +376,7 @@ private void configureEndpoint(AbstractKafkaListenerEndpoint<K, V> aklEndpoint)
376376
protected void initializeContainer(C instance, KafkaListenerEndpoint endpoint) {
377377
ContainerProperties properties = instance.getContainerProperties();
378378
BeanUtils.copyProperties(this.containerProperties, properties, "topics", "topicPartitions", "topicPattern",
379-
"messageListener", "ackCount", "ackTime", "kafkaConsumerProperties");
379+
"messageListener", "ackCount", "ackTime", "consumerProperties", "kafkaConsumerProperties");
380380
JavaUtils.INSTANCE
381381
.acceptIfNotNull(this.afterRollbackProcessor, instance::setAfterRollbackProcessor)
382382
.acceptIfCondition(this.containerProperties.getAckCount() > 0, this.containerProperties.getAckCount(),

0 commit comments

Comments
 (0)