我在哪里定义主题。元数据。刷新间隔太太

Question

我正在测试kafka，希望很快能把它放在我的生产堆栈中。
我正在使用文件kafka-console-producer.sh和kafka-console-consumer.sh来测试kafka的功能。

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

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

我正在尝试更改此设置，但我不知道在哪里？

Answer 1

我知道您指的是Java客户端，Jaya的回答就足够了。如果您正在使用构建在librdkafka之上的客户端配置，那么配置可能会略有不同：

https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md

元数据。最大年龄。ms：
元数据缓存最长期限。默认为元数据。刷新间隔ms*3。类型：整数

topic.metadata.refresh.interval.ms：
主题元数据刷新间隔，以毫秒为单位。元数据会在出错时自动刷新并连接。使用-1禁用间隔刷新。类型：整数

Answer 2

您还可以在producer类中设置它：

Properties props = new Properties();
props.put("topic.metadata.refresh.interval.ms", "10");
ProducerConfig config = new ProducerConfig(props);

Answer 3

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

<代码>服务器。属性，生产者。属性，消费者。属性

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

自主题。元数据。刷新间隔ms是生产者配置，您需要在生产者中添加此属性。属性文件

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