kafkaストリームプロセッサapiグローバル状態ストア複数のトピック

Question

私はカスタムプロセスを持っているので、プロセッサapiを使用してカフカストリームを作成しようとしています。私はプロセッサが異なる数のパーティションを持つ複数のトピックにリスニングしていたときに問題に直面しました。私は、グローバルな状態ストアを作成する必要があることに気付きました。 プロセッサを追加する方法と、複数のトピックをリッスンしながらグローバルステートストアを追加する方法を知る必要がありますか？

コード例やリンクが役立ちます。 ありがとうございました！

Answer 1

グローバル・ステート・ストアは、単一のトピックからのみ読み取ることができます。ただし、トピックごとに1つのグローバルストアを作成できます。また、グローバルストアはプロセッサに追加する必要はなく、すべてのプロセッサが自動的にアクセスできます。

私たちの例のレポは役立つはず：https://github.com/confluentinc/kafka-streams-examples

はまた、ドキュメントをチェックアウト：http://docs.confluent.io/current