我正在对 kafka 进行一些测试，希望很快就能将其放入我的生产堆栈中。
我正在使用这些文件kafka-console-producer.sh and kafka-console-consumer.sh测试kafka的功能。
我创建了一个包含 2 个分区的主题，但我发现我的生产者发送的所有消息都将发送到一个分区。
我在互联网上搜索了这个并读到有一个名为topic.metadata.refresh.interval.ms它告诉生产者更改当前正在写入的分区，默认值为 10 分钟。
我正在尝试更改此设置，但我不明白在哪里......？
Kafka属性可以在以下三个文件中找到
server.properties, producer.properties, consumer.properties
这些文件将在文件夹中可用kafka-folder/config/。默认情况下，这些文件中的某些属性将可用。您可以添加任何您想要的属性。此链接中给出了属性列表https://kafka.apache.org/08/configuration.html https://kafka.apache.org/08/configuration.html。此链接包含服务器、生产者和消费者的所有属性的详细说明。
Since topic.metadata.refresh.interval.ms是生产者配置，需要在producer.properties file
注意上面的链接是属性配置kafka-0.8版本.
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
