小编Sha*_*dra的帖子

Kafka - 如何使用 @KafkaListener(topicPattern="${kafka.topics}") ,其中属性 kafka.topics 是“sss.*”?

我正在尝试以主题名称作为模式来实现 Kafka 消费者。例如 @KafkaListener(topicPattern="${kafka.topics}") 其中属性 kafka.topics 是 'sss.*'。现在,当我向主题“sss.test”或任何其他主题名称(如“sss.xyz”、“sss.pqr”)发送消息时,它会抛出如下错误:

警告 o.apache.kafka.clients.NetworkClient - 获取相关 ID 为 12 的元数据时出错:{sss.xyz-topic=LEADER_NOT_AVAILABLE}

我尝试在 server.properties 文件中启用侦听器和 Advertisingd.listeners,但是当我重新启动 Kafka 时,它会消耗来自已尝试的所有旧主题的消息。当我使用新的主题名称时,它会抛出上述错误。

Kafka不支持模式匹配?或者我缺少一些配置?请建议。

consumer apache-kafka spring-kafka

5
推荐指数
0
解决办法
4441
查看次数

标签 统计

apache-kafka ×1

consumer ×1

spring-kafka ×1