apache-kafka - 我在哪里定义 topic.metadata.refresh.interval.ms？

Question

我正在对 kafka 进行一些测试，希望能尽快将其放入我的生产堆栈中。
我正在使用文件 kafka-console-producer.sh 和 kafka-console-consumer.sh 来测试 kafka 的功能。

我创建了一个包含 2 个分区的主题，但我看到我的生产者发送的所有消息都将发送到一个分区。

我在互联网上搜索了这个并读到有一个名为 topic.metadata.refresh.interval.ms 的设置告诉生产者更改它当前正在写入的分区，并且默认是 10 分钟。

我正在尝试更改此设置，但我不明白在哪里...？

Answer 1

Kafka 属性可以在以下三个文件中找到

server.properties、producer.properties、consumer.properties

这些文件将在文件夹 kafka-folder/config/ 中可用。默认情况下，某些属性将在这些文件中可用。您可以添加任何您想要的属性。此链接 https://kafka.apache.org/08/configuration.html 中给出了属性列表 。此链接包含服务器、生产者和消费者的所有属性的详细说明。

由于 topic.metadata.refresh.interval.ms 是生产者配置，您需要在 producer.properties< 中添加此属性文件

注意上面的链接是kafka-0.8版本的属性配置。