将 TOML 配置字段传递给 Spring KafkaListener Annotation答案

【问题标题】：Pass a TOML configuration field to a Spring KafkaListener Annotation将 TOML 配置字段传递给 Spring KafkaListener Annotation
【发布时间】：2018-10-15 19:53:50
【问题描述】：

我有一个 toml 文件用于配置使用 Spring 框架的 KafkaListener 注释的应用程序，其签名如下：

@KafkaListener(id = "id0", topics = "some.hard.coded.topic.name")

我有一个配置管理器类，它读取 TOML 文件并根据应用程序运行的环境配置各种应用程序设置。其中之一是要听的主题。但是，我不知道如何将其传递给 Kafka Listener 注释。我的理解是，这可以结合使用 SPEL 和 yml 文件来完成，但我在这里有点拘泥于使用 TOML。任何人都可以建议吗？

【问题讨论】：

标签： java spring annotations spring-kafka toml

【解决方案1】：

@KafkaListener 的topics 属性确实支持包括BeanFactory 访问的SpEL，因此，如果您有一些bean 可以读取该TOML 文件并将其表示为一组运行时属性，例如吸气剂，那么您绝对可以在那里获得SpEL。例如：

topics = "#{myTomlService.getTopic()}"

myTomlService 是上述服务的 bean 名称。

【讨论】：