Kafka消费者仍然需要动物园管理员的财产？

Question

我在这里指的是一篇帖子：在ApacheKafka多节点集群中连接Zookeeper

这里提到，从KafkaV9版开始，制作人和消费者不必使用zookeeper。连接属性和引导。服务器足以生成/使用数据。

我的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的情况下，我在消费者方面遇到了以下问题。连接属性。有人在没有zookeeper connect属性的情况下让消费者部分工作吗？

[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

只有新的消费者可以在不连接到动物园管理员的情况下工作，这在Kafka客户端工件中是可用的。您必须添加依赖项：

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

并使用org.apache.kafka.clients.consumer.包中的实现。