動物園管理員的財產仍然是卡夫卡消費者的要求？

Question

我指的是一個帖子在這裏： Connecting to Zookeeper in a Apache Kafka Multi Node cluster

其提及的是從卡夫卡V9版本，生產者和消費者不必使用zookeeper.connect財產，只是bootstrap.servers足以生產者/消費者數據。

我的pom.xml看起來像這樣在消費者方面：

<properties> 
    <java.version>1.7</java.version> 
    <kafka.version>0.9.0.1-cp1</kafka.version> 
    <kafka.scala.version>2.11</kafka.scala.version> 
    <confluent.version>2.0.1</confluent.version> 
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> 
</properties> 


<dependency> 
<groupId>org.apache.kafka</groupId> 
<artifactId>kafka_2.10</artifactId> 
<version>0.10.0.0</version> 
</dependency> 

我碰上在消費端的以下問題，不zookeeper.connect財產。有沒有人有消費者部分沒有zookeeper連接屬性工作？

[WARNING] 
java.lang.reflect.InvocationTargetException 
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) 
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
at java.lang.reflect.Method.invoke(Method.java:606) 
at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297) 
at java.lang.Thread.run(Thread.java:745) 
Caused by: java.lang.IllegalArgumentException: requirement failed: Missing required property 'zookeeper.connect' 
at scala.Predef$.require(Predef.scala:233) 
at kafka.utils.VerifiableProperties.getString(VerifiableProperties.scala:177) 
at kafka.utils.ZKConfig.<init>(ZkUtils.scala:902) 
at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:101) 
at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:105) 
at io.confluent.examples.consumer.ConsumerGroup.<init>(ConsumerGroup.java:30) 
at io.confluent.examples.consumer.ConsumerGroup.main(ConsumerGroup.java:113) 
... 6 more 

Answer 1

只有新的消費者沒有連接到Zookeeper並且可以在kafka-clients工件中使用。您必須添加依賴項：

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka-clients</artifactId> 
    <version>0.10.0.0</version> 
</dependency> 

並使用來自org.apache.kafka.clients.consumer.包的實現。