阿帕奇卡夫卡SimpleConsumer例

我下面這個頁面上的卡夫卡文檔，並試圖獲得SimpleConsumer運行起來：阿帕奇卡夫卡SimpleConsumer例

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

當我嘗試運行它在Java 1.7，斯卡拉2.11和卡夫卡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());

有什麼建議嗎？

編輯：我設法得到這項工作。我將我的卡夫卡版本更改爲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？

來源

2016-01-13 sparkr

你應該使用：
4.任何經紀主機名或IP地址
5. 9092是在配置中指定的默認端口，所以這應該是罰款

BTW，以防萬一你有一個分區，你知道分區ID從0開始？

來源

2016-01-14 02:36:16

您將有位於在配置文件中提供這些信息：`

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

與性質命名如下：

端口（默認爲9092，但你可以自己定義爲好）
host.name（默認爲本地主機，你可以定義你的經紀人IP /主機名）

謝謝

來源

2016-02-19 16:11:45 Afsar

卡夫卡通過Apache Kafka獲得了非常好的文檔，您可以找到關於消費者，用戶還有各種配置，分區等等的信息。

來源

2016-04-13 04:14:01 Prasad

阿帕奇卡夫卡SimpleConsumer例

回答

相關問題