Skip to content

Commit e87b076

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 e09340a commit e87b076

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
@@ -389,7 +389,7 @@ private void configureEndpoint(AbstractKafkaListenerEndpoint<K, V> aklEndpoint)
389389
protected void initializeContainer(C instance, KafkaListenerEndpoint endpoint) {
390390
ContainerProperties properties = instance.getContainerProperties();
391391
BeanUtils.copyProperties(this.containerProperties, properties, "topics", "topicPartitions", "topicPattern",
392-
"messageListener", "ackCount", "ackTime", "kafkaConsumerProperties");
392+
"messageListener", "ackCount", "ackTime", "consumerProperties", "kafkaConsumerProperties");
393393
JavaUtils.INSTANCE
394394
.acceptIfNotNull(this.afterRollbackProcessor, instance::setAfterRollbackProcessor)
395395
.acceptIfCondition(this.containerProperties.getAckCount() > 0, this.containerProperties.getAckCount(),

0 commit comments

Comments
 (0)