Etcdは、分散レプリケートされたキー値ストアを提供します。 4つのクラスターetcdのセットアップがあるとします。私はただ1人のプロデューサーしかいないとしましょう。さまざまなキーイベントの間でメッセージキューを模倣するために使用することができます。プロデューサによって生成された以下の4つのイベントがあるとします。1.追加:key1、value1 2.追加:key2、value2 3.変更:key2、value3 4.変更:key1、value4。すべての消費者が同じ順序でこれらのイベントを見ますか?カフカのような単一のプロデューサーのメッセージバスとして使用できますか?
0
A
答えて
0
キューとしてetcdを使用し、イベントの順序を維持できるはずです。 https://coreos.com/etcd/docs/latest/api.html#atomically-creating-in-order-keys
カフカはこのユースケースにはるかに適しています。順序を維持するには、単一パーティションでトピックを使用する必要があります。
カフカがサポートしている機能のいくつか、消費者がオフラインになって戻ってくるときの対応方法について考えてみてください。消費者団体?
関連する問題
- 1. 春のカフカ、TCPポートをプロデューサーとして
- 2. プロデューサーなし。最新のapacheカフカのドキュメント
- 3. エラー<p> カフカ</p>に私がプロデューサーを作るしようとしていますカフカ
- 4. カフカにカスタムデータを返すことができます。プロデューサー
- 5. カフカのプロデューサーがサーバーにデータを送信できません
- 6. カフカでプロデューサーに通知するには?
- 7. カフカのプロデューサーは非常に遅い
- 8. メッセージバスとしてのスプリングステートマシン
- 9. はカフカからカフカ(バージョン0.90)にアクセスしようとしているときに
- 10. ucharの配列を単一のucharとして使用できますか?
- 11. 単純なプロデューサーとコンシューマーのunique_lockでの難しさ
- 12. 一種の単純な多型に使用できますか?
- 13. カフカのプロデューサーとコンシューマーを同期させる
- 14. BookSleeveのConnectionUtils.Connect()を使用して、RedisメッセージバスのフェイルオーバーでSignalRを使用する
- 15. カフカのプロデューサーがPORTからトピックにデータを生成
- 16. カフカを使用してファイルを転送することはできますか?
- 17. 単一のBluemixブロックチェーンサービスを使用して複数のチェーンコードを使用することはできますか?
- 18. は、クラスインスタンスを一時的なものとしてのみ使用するように制限できますか?
- 19. キャンバス要素を使用してタイルから単一のマップイメージを作成しようとしています
- 20. どのようにしてdijkstraを使って単一のソースの宛先グラフを解決できますか?
- 21. GETとPOSTの両方を単一の形式で使用できますか?
- 22. instagramのような同じタイムラインをデザインするには、単一のUITableViewを使用していますか?
- 23. データの一部をロックとして使用できますか?
- 24. カフカは私がScalaの下に でストリームカフカを使用しようとしていますスカラ座
- 25. 複数のGSMモデムを使用して、単一の番号との間でSMSを処理できますか?
- 26. 単一レイヤWindowsフォームアプリケーションにはどのような基本アーキテクチャを使用できますか?
- 27. カフカはカフカの設定を使用して
- 28. マルチプロセスは単一の論理コアを使用しているようです
- 29. カフカのプロデューサーは30003にMSが最後に追記以来
- 30. HTTP負荷分散用のメッセージバスを探しています