2016-12-29 3 views
1

jarの違いを教えてください。 12です。私は1からKafkaConsumerのpoll(long timeout)APIを使用してブローカからデータを取得するためにkafkaクライアントを作成しようとしていますが、実装は自動生成されているようです(下記参照)。右の瓶が何であるかについての考え。適切なApache Kafka Client jarとは何ですか

public Map<String, ConsumerRecords<K,V>> poll(long timeout) { 
    return null; 
} 
+0

第二1上の '_2.9.2'サフィックスはあなたにそれがに対してコンパイルされたのScalaのバージョンを伝えるに書き込むことが第一瓶を使用する必要があります。 Scalaは常に後方互換性があるわけではないので、さまざまなScalaバージョンのjarファイルを提供しています(https://kafka.apache.org/downloads.htmlを参照)。接尾辞なしで1つも見られず、第1の依存関係にはScalaの依存関係が列挙されていません。 –

答えて

1

多くのプログラミング言語で利用可能なクライアントがあります。主なKafkaプロジェクトの一環として、Javaクライアントのみが管理されています。 clientsについてさらに確認できます。

あなたはカフカの消費者すなわち

<dependency> 
    <groupId>org.apache.kafka</groupId> 
    <artifactId>kafka-clients</artifactId> 
    <version>0.8.2.0</version> 
</dependency> 
+0

こんにちは@ravthiru、答えをありがとう。 poll()APIに関する私の2番目の質問に対する答えを知っていますか? Javaクライアントに自動生成コードがあるのはなぜですか?ありがとう! – useful

+0

IRRC、クライアントはKafka 0.9で独自のjarファイルを作成しました - もしKafka 0.8.2ならKafkaコアに依存する必要があります。 –

+1

あなたが参照しているコアジャーのmaven設定を提供してもよろしいですか? https://mvnrepository.com/artifact/org.apache.kafkaのどれが正しいかわからないのですか? – useful

関連する問題