2

問題

各 HA ペアに NFS を使用した複数のデータセンターの activeMQ セットアップがあり、activeMQ は実際にはスケーラブルではなく、NFS の問題でうまく機能しないようです。(5.7を使用しています)

可能な解決策

カフカに移動

要件

  • PointToPoint と pub/sub 機能が必要です
  • メッセージの優先順位 (kafka がそれをすぐに提供しないことは知っていますが、私たちの側で回避策があります)

質問

これは Kafka で可能ですか (必ずしもすぐに使用できるわけではありませんが、クライアントの調整が必要です)。そうでない場合、他にどのようなテクノロジを提案しますか? JMS である必要はありませんが、スケーラブルで信頼できる必要があります (また、NFS とうまく連携する必要があります)。

4

4 に答える 4

1

PointToPoint と pub/sub 機能が必要です

カフカはそれを行い、ここで私の発見を共有しました

メッセージの優先度

正確に何を意味するのか少し混乱しましたが、特定のオフセットから消費することを意味する場合、優先度によって、低レベルまたはシンプルなコンシューマー API がそれを提供します。メッセージの再送信にも対応

于 2013-08-30T11:19:23.963 に答える
0

メッセージのポイント ツー ポイント配信 (単一のプロデューサー、単一のコンシューマー) の場合、パーティションの数を 1 として構成できます。プロデューサーはこのトピックとパーティションでメッセージを発行し、単一のコンシューマーはそのトピックとパーティションから読み取ります。トピックは、ActiveMQ 用語ではキューに相当します。

メッセージの優先度を追加したい場合は、低レベルの Kafka クライアントを使用します。その後、パーティションの数を増やし (各パーティションは異なる優先度レベルのメッセージに対応)、コンシューマーに最も優先度の高いトピックからメッセージをフェッチさせることができます。 、メッセージが存在しない場合は、次に優先度の低いトピックからフェッチされます。

于 2016-04-12T21:44:05.980 に答える
0

Kafka は、ポイント ツー ポイントおよびパブリッシュ サブスクライブの使用パターンをユーザー グループの概念別に提供します。直接サポートされていないのは、セレクター、優先順位です。ただし、パーティション間でメッセージを配布する可能性があるため、たとえば、優先度に基づいてメッセージをパーティションに配布できます。また、保持ポリシーによって制限されたメッセージの永続性 (コア原則の 1 つ) を無料で利用できます。kafka の各メッセージは、基本的にキーと値のペアです。キーには、パーティショニングとログ圧縮における特定のセマンティクスがあります。ルーティングなどに使用できるカスタムヘッダーを使用できる従来のメッセージングシステムのようなものはありません.次の記事はそれを要約しようとします.

于 2016-11-03T21:15:16.387 に答える