投稿日: Oct 20, 2023
本日 Amazon Managed Streaming for Apache Kafka (Amazon MSK) は、MSK サービスコンソールの Amazon EventBridge Pipes との統合を発表しました。これにより、Apache Kafka クラスターからイベントを、14 を超える AWS のサービスターゲット (Amazon SQS、Amazon Kinesis Data Streams と Firehose、AWS Step Functions、Amazon SNS、Amazon EventBridge イベントバスなど) のいずれかに簡単に送信できるようになります。EventBridge Pipes 統合では、EventBridge API 送信先ターゲットもサポートされます。これは、API 呼び出しを使用して、AWS 内外でイベントを Software as a Service (SaaS) アプリケーションまたは独自のアプリケーションに送信します。
Kafka クラスターから流れてくるデータは簡単に取得できます。クラスターを選択し、アクションメニューから [EventBridge パイプの作成] をクリックして接続に名前を付け、その後ターゲットを選択するだけです。バッチサイズ、バッチウィンドウ、開始位置などは、必要に応じてカスタマイズが可能です。オプションのフィルタリングステップを使用すると、特定のイベントのみをパイプに流し込めます。また、AWS Lambda、AWS Step Functions、API 送信先、あるいは Amazon API Gateway を活用したオプションの強化ステップを使用すれば、ターゲットに到達する前のイベントを強化または変換できます。EventBridge Pipes 統合では、差別化につながらない統合コードを記述、管理、スケールする必要がないため、サービスの接続ではなく、サービスの構築に時間をかけることができます。
開始するには、MSK コンソールでクラスターを選択し、アクションメニューから [EventBridge Pipe の作成] を選択します。または、AWS ニュースブログ記事で、Amazon EventBridge Pipes がサービスをより簡単に統合するうえでいかに役立つかをご確認ください。