消费者不会从订阅后创建的主题中获取消息

Question

我已经创建了一些 KafkaConsumer，接下来调用订阅（使用模式），然后进行下一次轮询。 我注意到如果我的消费者 运行，稍后我创建了一些新主题（与模式匹配），这个消费者将不会消费这些数据！如果我重新启动我的应用程序，那么消费者会从新创建的主题中获取数据。 没关系 ？我该如何解决？

Answer 1

KafkaConsumer 将根据 KafkaConsumer 配置metadata.max.age.ms刷新其订阅的元数据，默认为 5 分钟。

您可以减少此配置，让您的消费者也使用与您的模式匹配的新创建的主题。