在 Kafka Producer 中设置 zookeeper.connect 属性
Set zookeeper.connect property in Kafka Producer
我使用的是Kafka0.8.1。我需要在实例化 Producer 时设置 zookeeper.connect 属性。我正在这样设置 属性：
Properties props = new Properties();
props.put("zookeeper.connect","zookeeper2:2181,zookeeper3:2181,zookeeper1:2181/kafka");
但是，kafka 一直在抱怨这个：
[main] utils.Logging$class(83): Property zookeeper.connect is not
valid
我看过这里：https://kafka.apache.org/08/configuration.html
尽管如此，我还是不明白 "zookeeper.connect" 值有什么问题。如果有人能指出错误，我将不胜感激。
根据 configuration 页面 zookeeper.connect 是 Broker and/or Consumer 的 属性，而不是制作人 属性，您需要设置 metadata.broker.list，这是 section 3.3 Producer Configs。
希望对您有所帮助！
我刚刚添加了以下行：
properties.setProperty("zookeeper.connect", "localhost:2181");
我使用的是Kafka0.8.1。我需要在实例化 Producer 时设置 zookeeper.connect 属性。我正在这样设置 属性：
Properties props = new Properties();
props.put("zookeeper.connect","zookeeper2:2181,zookeeper3:2181,zookeeper1:2181/kafka");
但是，kafka 一直在抱怨这个：
[main] utils.Logging$class(83): Property zookeeper.connect is not valid
我看过这里：https://kafka.apache.org/08/configuration.html 尽管如此，我还是不明白 "zookeeper.connect" 值有什么问题。如果有人能指出错误，我将不胜感激。
根据 configuration 页面 zookeeper.connect 是 Broker and/or Consumer 的 属性，而不是制作人 属性，您需要设置 metadata.broker.list，这是 section 3.3 Producer Configs。
希望对您有所帮助！
我刚刚添加了以下行：
properties.setProperty("zookeeper.connect", "localhost:2181");