2

イベント処理ドメインは初めてです。私は自分の要件を満たす Java ベースのイベント処理フレームワークを探しています。私は無数のフレームワーク (Apache Storm、Apache Kafka、RabbitMQ などの従来のイベント ブローカー) に関するドキュメントとチュートリアルの迷路を通り抜けてきました。私は賢明ではありません。

私の要件は次のとおりです。プッシュされるイベントのソース (使用状況の追跡など) があります。私は彼らと一緒に次のことをしたいと思っています:

  1. バケット化（顧客ごとなど、異なるバケットに分割）
  2. バケット化されたすべてのイベントをバッチとしてデータベースに挿入します。
  3. なんらかの負荷分散/イベントの優先順位付けを実行します。たとえば、優先度の低い顧客に大きな反対を押してほしくありません。少数のイベントで優先度の高い顧客を飢えさせるイベントの数。

イベントの順序についてはあまり気にしませんが、これらのシステムの高可用性を確保したいと考えています。

開始するためのいくつかの指針を探しています。テクノロジ インフラストラクチャには障害はありませんが、Java ベースの何かです。

4

1 に答える 1

4

リアルタイムの分散データ処理を行うための優れたフレームワークがあります。

あなたの場合、これらのフレームワークのいずれかを選択することは、ハンマーでナッツを割るようなものだと思います。Kafka クラスターに加えて、マスター ノードとワーカー ノードを含むクラスターをデプロイして管理する必要があります。

アーキテクチャをシンプル、スケーラブル、高可用性に保つには、KafkaStreams を検討する必要があります。KafkaStreamsは、kafka トピックでリアルタイム計算を行うための新しい Java API (kafka 0.10 以降で使用可能) です。

KafkaStreams アプリケーションは単純な Java アプリケーションであるため、既存のアプリケーションにジョブを埋め込むことができます。

また、Kafka Streams ジョブは、単純なコマンド java -jar でデプロイできます。

于 2016-07-12T22:38:41.537 に答える