使用例

MongoDB Kafka ソース コネクタを構成し、特定のタスクを実行する方法については、次のセクションをお読みください。

• 集計パイプラインによる MongoDB Change Stream のフィルタリングと変換

• 複数の MongoDB コレクションの変更をリッスン

• Source Connector がレコードを公開するトピックの名前をカスタマイズする

• MongoDB コレクションから Apache Kafka トピックへのデータのコピー

• Source Connector によって処理されるドキュメントがスキーマに準拠していることを確認する