Apache Kafka SimpleConsumer 示例答案

【问题标题】：Apache Kafka SimpleConsumer ExampleApache Kafka SimpleConsumer 示例
【发布时间】：2016-01-13 19:19:51
【问题描述】：

我正在关注此页面上的 Kafka 文档并尝试启动并运行 SimpleConsumer：

https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example

当我尝试在 Java 1.7、Scala 2.11 和 Kafka 0.9.0.0 上运行它时，我无法再编译该文件：

[error] /Users/jothi/Sandbox/jaguar/spark-kafka-consumer/src/main/java/com/eon/vpp/SimpleExample.java:175: error: host has private access in Broker
[error]                 m_replicaBrokers.add(replica.host());

有什么建议吗？

编辑：我设法完成了这项工作。我将 Kafka 版本更改为 0.8.0！

我如何使用这个消费者？我目前执行以下操作：

joe$ java -cp spark-kafka-consumer-0.1.0-SNAPAHOT.jar com.eon.vpp.SimpleMetricsConsumer 10000 test_topic 1 9092

程序需要 5 个参数：

1. Maximum number of messages to read (so we don’t loop forever)
2. Topic to read from
3. Partition to read from
4. One broker to use for Metadata lookup
5. Port the brokers listen on

我应该为参数 4 和 5 使用什么？

【问题讨论】：

标签： apache-kafka

【解决方案1】：

您应该使用：
4. 任何代理主机名或 IP 地址
5. 9092 是配置中指定的默认端口，因此应该没事的

顺便说一句，万一你有一个分区，你知道分区ID从0开始吗？

【讨论】：

【解决方案2】：

您将在位于以下位置的配置文件中获得这些信息：`

${kafka-folder}/config/server.properties

属性名称如下：

端口（默认为 9092，但您也可以自己定义）
host.name（默认为 localhost，您可以定义您的代理 IP/主机名）

谢谢

【讨论】：

【解决方案3】：

Kafka 通过Apache Kafka 阅读了非常好的文档，您可以找到有关消费者、订阅者以及各种配置、分区等的信息。

【讨论】：