Update Consumer config

[MrAolen]

Hi,

Is it possible to update consumer config after their instantiation ? In particular, I would like to add interceptor to the config.

Thanks in advance.

[garyrussell]

Yes, since version 2.7 you can modify the consumer factory properties.

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/core/ConsumerFactory.java

Lines 207 to 214 in 8bcb052

	/**
	* Update the consumer configuration map; useful for situations such as
	* credential rotation.
	* @param updates the configuration properties to update.
	* @since 2.7
	*/
	default void updateConfigs(Map<String, Object> updates) {
	}

Since version 2.3, you can override/supplement the consumer factory properties via the container properties.

spring-kafka/spring-kafka/src/main/java/org/springframework/kafka/listener/ConsumerProperties.java

Lines 319 to 348 in 8bcb052

	/**
	* Get the consumer properties that will be merged with the consumer properties
	* provided by the consumer factory; properties here will supersede any with the same
	* name(s) in the consumer factory. You can add non-String-valued properties, but the
	* property name (hashtable key) must be String; all others will be ignored.
	* {@code group.id} and {@code client.id} are ignored.
	* @return the properties.
	* @see org.apache.kafka.clients.consumer.ConsumerConfig
	* @see #setGroupId(String)
	* @see #setClientId(String)
	*/
	public Properties getKafkaConsumerProperties() {
	return this.kafkaConsumerProperties;
	}
	/**
	* Set the consumer properties that will be merged with the consumer properties
	* provided by the consumer factory; properties here will supersede any with the same
	* name(s) in the consumer factory.
	* {@code group.id} and {@code client.id} are ignored.
	* Property keys must be {@link String}s.
	* @param kafkaConsumerProperties the properties.
	* @see org.apache.kafka.clients.consumer.ConsumerConfig
	* @see #setGroupId(String)
	* @see #setClientId(String)
	*/
	public void setKafkaConsumerProperties(Properties kafkaConsumerProperties) {
	Assert.notNull(kafkaConsumerProperties, "'kafkaConsumerProperties' cannot be null");
	this.kafkaConsumerProperties = kafkaConsumerProperties;
	}

In either case, you have to restart the container(s) for it to take effect.

[MrAolen]

Works like a charm. Thanks !

[KhaiNguyenDuc]

Thanks, It's work