@KafkaListener 使用 SpEL 表达式设置属性

Question

是否可以使用 SpEL 将属性列表注入到 @KafkaListner 注释中？

像这样：

@KafkaListener(topics = "topic-name",
            containerFactory = "myContainerFactory",
            groupId = "group-id",
            properties = "#{kafka.consumer.custom.properties}")
    public void onMessage(String msg) {
        log.info(msg);
    }

application.yml

kafka:
  consumer:
    custom:
      properties:
        key.deserializer: org.apache.kafka.common.serialization.IntegerDeserializer
        value.deserializer: org.apache.kafka.common.serialization.StringDeserializer

Answer 1

见https://github.com/spring-projects/spring-kafka/issues/1880#issuecomment-887677779

some:
  prop: |
    max.poll.records: 10
    fetch.min.bytes: 123456

@KafkaListener(id = "kgh1880", topics = "kgh1880",
            properties = "${some.prop}")

@KafkaListener 使用 SpEL 表达式设置属性

@KafkaListener setting properties using SpEL expression

apache-kafka

spring-boot

spring-kafka