Spring Boot @KafkaListener使用SPEL无法获取Bean配置的Topic名称

核心问题：SPEL表达式被当作字面量解析 #

你当前的@KafkaListener配置中，SPEL表达式被单引号包裹（#{'kafkaProps.topicZZZ'}），导致Spring将其直接视为字符串字面量，而不会解析对应的Bean属性，这就是日志显示Subscribed to topic(s): kafkaProps.topicZZZ的原因。

修复步骤 #

1. 修正SPEL表达式语法 #

去掉表达式外层的单引号，直接使用#{kafkaProps.topicZZZ}格式：

@KafkaListener(topics = {"#{kafkaProps.topicZZZ}" }, 
               groupId = "#{kafkaProps.groupId}", containerFactory = "onlineKafkaListenerContainerFactory")
public void consumeOnlineMessages() {
    log.info("Consuming message...");
}

2. 确保Bean属性可被SPEL访问 #

虽然public字段可以被SPEL直接访问，但Spring更推荐通过标准getter方法访问属性，同时避免字段暴露的风险。修改KafkaProperties类，添加getter/setter：

class KafkaProperties {
    private String topicZZZ;
    private String groupId;

    // Getter & Setter
    public String getTopicZZZ() {
        return topicZZZ;
    }

    public void setTopicZZZ(String topicZZZ) {
        this.topicZZZ = topicZZZ;
    }

    public String getGroupId() {
        return groupId;
    }

    public void setGroupId(String groupId) {
        this.groupId = groupId;
    }
    // 其他字段与方法
}

3. 明确Bean名称（可选但推荐） #

你的KafkaConfig中，populateKafkaProperties方法返回的Bean默认名称是方法名populateKafkaProperties，虽然@Autowired通过类型+@Primary可以注入到kafkaProps变量，但为了避免SPEL解析时的名称歧义，建议在@Bean注解中明确指定Bean名称：

class KafkaConfig {
    @Bean(name = "kafkaProps")
    @Primary
    public KafkaProperties populateKafkaProperties() {
        KafkaProperties obj = new KafkaProperties();
        obj.setTopicZZZ("kafkaTopicName");
        obj.setGroupId("your-consumer-group-id"); // 记得设置groupId，否则会为null
        return obj;
    }
}

4. 排查之前的SPEL解析错误 #

如果之前直接使用#{someBean.someProperty}报错，大概率是以下原因：

• Bean名称错误：确保someBean是Spring容器中实际存在的Bean名称（比如方法名或@Bean(name)指定的名称）
• 属性无getter方法：SPEL默认通过getter访问属性，而非直接访问字段
• Bean未被正确初始化：检查KafkaConfig是否被Spring扫描到（比如添加了@Configuration注解）

验证 #

启动应用后，日志应显示订阅了正确的topic名称（kafkaTopicName），此时消费者即可正常接收消息。

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