カフカストリーム - <a href="http://docs.confluent.io/current/streams/developer-guide.html" rel="nofollow noreferrer">Kafka Streams Developer Guide</a>で複数のクラスタに接続する

Question

それは言う：

一つカフカクラスタのみ：現在カフカストリームのアプリケーションは、この設定値で指定された単一カフカのクラスタにのみ 話すことができます。 将来、Kafka Streamsは、 カフカクラスターへの接続をサポートし、入力ストリームの読み取りや出力の書き込みを行うことができます。 ストリーム。これは私の全体のアプリケーションは、単一のカフカのクラスタに接続することができますかKafkaStreamsの各インスタンスは、単一のクラスタに接続できることを

を意味するのでしょうか？

異なるクラスターに接続するプロパティが異なる複数のKafkaStreamsインスタンスを作成できますか？

ありがとう

Answer 1

これは、1つのアプリケーションが1つのクラスタにしか接続できないことを意味します。

• あなたはそれが同じインスタンスを持つ2つの異なるクラスタからの二つのトピックを読んですることはできませんクラスタAからトピックを読み、B.
• をクラスタ化するために、あなたの計算の結果を書き込むことはできません。

異なるクラスターに接続するプロパティが異なる複数のKafkaStreamsインスタンスを作成できますか？

はい、絶対に。しかし、これらの異なるインスタンスは異なるアプリケーションになります。 （ "消費者団体" を考えてみてください。）

更新：あなたが好きなように

単一のJVM内では、できるだけ多くKafkaStreamsインスタンスを作成することができます。また、異なるクラスタに接続するように構成することもできます（同じ処理を実行する場合は、すべて同じクラスタをKStreamBuilderとして使用できます）。