SPEL 在 KafkaListener 中不工作。无法解析 属性

Question

我有一段代码，我在@KafkaListener 中使用了 SPEL。 我正在尝试提供对主题字段的全局变量引用，但出现错误

"Could not resolve placeholder 'topicKey.split(',')' in value "#{'${topicKey.split(',')}'}"

代码如下：

String topicKey =   "Topic1,Topic2";

@KafkaListener(topics = "#{'${topicKey.split(',')}'}")

有人可以帮我解决我在这方面遗漏的问题吗？

Answer 1

错误很明显

"Could not resolve placeholder 'topicKey.split(',')' in value "#{'${topicKey.split(',')}'}"

你的语法错误，假设 属性 是 topicKey，正确的语法是

@KafkaListener(topics = "#{'${topicKey}'.split(',')}")

属性先解决。

@KafkaListener(topics = "#{'foo,bar'.split(',')}")

然后 SpEL 拆分字符串。