本文介绍了卡夫卡消费者正在花时间识别新的分区的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我正在运行一个测试，其中Kafka使用者正在从一个主题的多个分区读取数据。在进程运行时，我添加了更多分区。使用者线程从新分区读取数据大约需要5分钟。我找到了这个配置"topic.metadata.renh.interval.ms"，但这只适用于生产者。消费者也有类似的配置吗？
推荐答案
我更改了"；metadata.Max.age.ms"；参数值以刷新元数据https://kafka.apache.org/documentation/#consumerconfigs_metadata.max.age.ms
这篇关于卡夫卡消费者正在花时间识别新的分区的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！