Sha*_*dra 5 consumer apache-kafka spring-kafka
我正在尝试以主题名称作为模式来实现 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不支持模式匹配?或者我缺少一些配置?请建议。
| 归档时间: |
|
| 查看次数: |
4441 次 |
| 最近记录: |