私は別々の2つのkafkaストリームアプリケーションを別々のJVMインスタンスにそれぞれ実行し、うまく動作しています。同じJVMインスタンスでアプリケーションを実行すると、2番目のアプリケーションは動作していません(データの消費もデータの生成もありません)。同じJVMインスタンス内で別々の2つのアプリケーションを実行する場合に制限はありますか?これはカフカの消費者にも起こりますか?KafkaStreamsアプリケーション
0
A
答えて
0
複数のKafkaStreams
インスタンスを同じJVMに入れることができます。しかし、1つのインスタンス内のスレッド数を増やす方が簡単かもしれません。
注:利用できるすべてのインスタンスのスレッド数は、入力トピックの入力パーティションの数によって制限されます(これは厳密ではありませんが、経験則としては厳密です)。入力トピックに十分なパーティションがありますか?一部のパーティションが処理されていないインスタンスに割り当てられていないことがわかりますか?
また、カフカストリームはスレッドごとに並列化します。つまり、スレッドが2つずつ2つのインスタンスがあり、入力トピックパーティションが2つだけの場合、両方のパーティションが1つのインスタンスの2つのスレッドに割り当てられますもう一方のインスタンスの2つのスレッドはアイドル状態です。実行時には、スレッドを「参照」し、同じまたは異なるKafkaStreams
インスタンス内でスレッドが実行されているかどうかはわかりません。
関連する問題
- 1. KafkaStreams(0.11)
- 2. KafkaStreams - InconsistentGroupProtocolException
- 3. KafkaStreamsのローカルステートストレージ
- 4. リアルタイムルール編集とKafkaStreams
- 5. kafkastreams - 処理能力を追加する
- 6. StateStoreSupplier KafkaStreamsにシーケンスを保存する
- 7. kafkaへの書き込みkafkastreamsを使用したレコードの内容に基づくトピック
- 8. KafkaStreams状態ストア初期化が繰り返してRocksDBフォルダを作成して削除します
- 9. mvcアプリケーションmvcアプリケーション
- 10. Azure AD B2CアプリケーションとAzureアプリケーション登録アプリケーション
- 11. C#アプリケーションのアプリケーション/フォームデータ?
- 12. エラー:アプリケーションは、アプリケーションの起動
- 13. JavaScriptアプリケーションのためのアプリケーション
- 14. SharePointアプリケーションのアプリケーションの洞察
- 15. QMLアプリケーションとQML/C++アプリケーション
- 16. アプリケーション設定スコープ - ユーザーvsアプリケーション
- 17. クライアント(Androidアプリケーション) - サーバー(Javaアプリケーション)
- 18. ActionScriptアプリケーションからAIRアプリケーションへ
- 19. Facebookアプリケーション - FB like - アプリケーションのURL
- 20. AndroidログインWebアプリケーションへのアプリケーション
- 21. Wpf Webアプリケーションへのアプリケーション
- 22. アプリケーション
- 23. アプリケーション
- 24. アプリケーション
- 25. アプリケーション
- 26. アプリケーション
- 27. アプリケーション
- 28. /アプリケーション
- 29. アプリケーション
- 30. XMLアプリケーションを持たないSpringアプリケーションとHibernateアプリケーション