我正在尝试用主题名作为模式来实现kafka消费者。e、 g.@kafkalistener(topicpattern=“${kafka.topics}”),其中kafka.topics属性是“sss.*”。现在,当我将消息发送到主题“sss.test”或任何其他主题名称(如“sss.xyz”、“sss.pqr”)时,会引发如下错误:
warn o.apache.kafka.clients.networkclient-获取相关id为12的元数据时出错:{sss.xyz topic=leader\u not\u available}
我试图在server.properties文件中启用listeners&advised.listeners,但当我重新启动kafka时,它会使用来自所有已尝试的旧主题的消息。当我使用新的主题名时,它抛出了上面的错误。
Kafka不支持模式匹配?或者我缺少一些配置?请建议。
暂无答案!
目前还没有任何答案,快来回答吧!