能否使用SpEL表达式向@KafkaListener注解注入属性列表？

当然可以！@KafkaListener注解的properties属性完全支持通过SpEL表达式注入属性列表，只要你的表达式能返回一个Map<String, Object>或者java.util.Properties类型的对象就行。

你的示例解析 #

你提供的代码和配置是完全可行的，具体逻辑如下：

1. 在application.yml中，kafka.consumer.custom.properties是嵌套的键值对结构，Spring会自动将其解析为一个Map<String, String>对象。
2. 在@KafkaListener的properties属性里，#{kafka.consumer.custom.properties}这个SpEL表达式会直接引用这个Map，把里面的键值对作为Kafka消费者的自定义属性注入。

启动应用后，对应的消费者容器会自动使用你配置的key.deserializer和value.deserializer，效果和硬编码写在properties={"key.deserializer": "...", "value.deserializer": "..."}完全一致。

扩展：用SpEL配置其他@KafkaListener属性 #

除了properties，@KafkaListener的其他核心属性也支持SpEL表达式，分享几个常见的动态配置场景：

• 动态指定topics
  如果topic名称配置在yml中：

  kafka:
    topics:
      user-events: "user-actions-v1"
  

  可以通过SpEL动态注入：

  @KafkaListener(topics = "#{kafka.topics.userEvents}", groupId = "user-action-group")
  public void onUserEvent(String msg) {
      // 处理消息
  }
  

• 动态指定groupId（带默认值）
  可以结合environment对象读取配置，还能设置默认值兜底：

  @KafkaListener(topics = "user-actions-v1", groupId = "#{environment.getProperty('kafka.consumer.userGroup', 'default-user-group')}")
  

• 动态选择containerFactory
  如果有多个容器工厂，可通过SpEL的条件表达式动态选择：

  @KafkaListener(topics = "user-actions-v1", containerFactory = "#{systemProperties['env'] == 'prod' ? 'prodKafkaFactory' : 'devKafkaFactory'}")
  

需要注意的是：SpEL表达式的返回类型要匹配属性的要求，比如topics接受字符串或字符串数组，properties必须返回Map或Properties对象。

内容的提问来源于stack exchange，提问作者Scott Stark