2017-05-19 5 views
0

を使用して動作していないコードスニペットの下に見つけてください:春キャメル-カフカ:1消費者と複数のトピックは、 'ラクダカフカ' コンポーネント

プロパティファイル:

consumer.topic=FIRST,SECOND 
consumer.group=group1 

Route.java:

from("kafka:{{kafka.url}}?topic={{consumer.topic}}&groupId={{consumer.group}}&autoOffsetReset=earliest&consumersCount={{consumer.consumersCount}}") 

トピックFIRSTSECONDの代わりに、単一のトピックとして検討されています2つの異なるものとみなされる。誰かが、プロパティファイルでどのように設定して2つに解決する必要があるのか​​を説明してくれますか?

LOG:

KafkaTopic[FIRST,SECOND]] Error while fetching metadata with correlation id 2159 : {FIRST,SECOND=INVALID_TOPIC_EXCEPTION} 
+0

のCaどのバージョンでありますあなたはメルですか? –

+0

Camel Version:2.17.0 JDK:1.8 – poram

答えて

2

これはラクダ2.17.0ではサポートされていません。

複数のトピックのサブスクリプションは、Camel 2.17.1以降とCamel 2.18.x以降から導入されました。ここで

は2.17.xブランチ上のこの変更に関連するコミットです: https://github.com/apache/camel/commit/a8f32d4ec485419cd196988f0de938d6f9b3cc49

、ここでは2.18.xブランチ上のこの変更に関連するコミットです: https://github.com/apache/camel/commit/d7fc67fa16d083e570650aa20c064d609b469641

あなたがにアップグレードする必要があり完全のためにキャメル> = 2.17.1または2.18.x

ここキャメルJIRA上の問題が https://issues.apache.org/jira/browse/CAMEL-9835

+0

:ありがとう、私は2.17.1にバージョンをアップグレードし、それは働いた。私は2.17にもっと集中していて、その子バージョンを無視しました。 :) – poram

関連する問題