Jump To Close Expand all Collapse all Table of contents Debezium ユーザーガイド 前書き 1. Debezium の概要 Expand section "1. Debezium の概要" Collapse section "1. Debezium の概要" 1.1. Debezium の機能 1.2. Debezium アーキテクチャーの説明 2. 必要となるカスタムリソースのアップグレード 3. Db2 の Debezium コネクター Expand section "3. Db2 の Debezium コネクター" Collapse section "3. Db2 の Debezium コネクター" 3.1. Debezium Db2 コネクターの概要 3.2. Debezium Db2 コネクターの仕組み Expand section "3.2. Debezium Db2 コネクターの仕組み" Collapse section "3.2. Debezium Db2 コネクターの仕組み" 3.2.1. Debezium Db2 コネクターによるデータベーススナップショットの実行方法 Expand section "3.2.1. Debezium Db2 コネクターによるデータベーススナップショットの実行方法" Collapse section "3.2.1. Debezium Db2 コネクターによるデータベーススナップショットの実行方法" 3.2.1.1. アドホックスナップショット 3.2.1.2. 増分スナップショット 3.2.2. Debezium Db2 コネクターによる変更データテーブルの読み取り方法 3.2.3. Debezium Db2 変更イベントレコードを受信する Kafka トピックのデフォルト名 3.2.4. Debezium Db2 コネクターのスキーマ変更トピック 3.2.5. トランザクション境界を表す Debezium Db2 コネクターによって生成されたイベント 3.3. Debezium Db2 コネクターのデータ変更イベントの説明 Expand section "3.3. Debezium Db2 コネクターのデータ変更イベントの説明" Collapse section "3.3. Debezium Db2 コネクターのデータ変更イベントの説明" 3.3.1. Debezium db2 変更イベントのキー 3.3.2. Debezium Db2 変更イベントの値 3.4. Debezium Db2 コネクターによるデータ型のマッピング方法 3.5. Debezium コネクターを実行するための Db2 の設定 Expand section "3.5. Debezium コネクターを実行するための Db2 の設定" Collapse section "3.5. Debezium コネクターを実行するための Db2 の設定" 3.5.1. 変更データキャプチャーの Db2 テーブルの設定 3.5.2. Db2 キャプチャーエージェント設定のサーバー負荷およびレイテンシーへの影響 3.5.3. DB2 キャプチャーエージェントの設定パラメーター 3.6. Debezium Db2 コネクターのデプロイ Expand section "3.6. Debezium Db2 コネクターのデプロイ" Collapse section "3.6. Debezium Db2 コネクターのデプロイ" 3.6.1. Db2 JDBC ドライバーの取得 3.6.2. AMQ Streams を使用した Db2 コネクターデプロイメント 3.6.3. AMQ Streams を使用した Debezium Db2 コネクターのデプロイ 3.6.4. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium Db2 コネクターのデプロイ 3.6.5. Debezium Db2 コネクターが実行していることの確認 3.6.6. Debezium Db2 コネクター設定プロパティーの説明 3.7. Debezium Db2 コネクターのパフォーマンスの監視 Expand section "3.7. Debezium Db2 コネクターのパフォーマンスの監視" Collapse section "3.7. Debezium Db2 コネクターのパフォーマンスの監視" 3.7.1. Db2 データベースのスナップショット作成時の Debezium の監視 3.7.2. Debezium Db2 コネクターレコードストリーミングの監視 3.7.3. Debezium Db2 コネクターのスキーマ履歴の監視 3.8. Debezium Db2 コネクターの管理 3.9. Debezium コネクターでのキャプチャーモードの Db2 テーブルのスキーマの更新 Expand section "3.9. Debezium コネクターでのキャプチャーモードの Db2 テーブルのスキーマの更新" Collapse section "3.9. Debezium コネクターでのキャプチャーモードの Db2 テーブルのスキーマの更新" 3.9.1. Debezium Db2 コネクターでのオフラインスキーマ更新の実行 3.9.2. Debezium Db2 コネクターでのオンラインスキーマ更新の実行 4. MongoDB の Debezium コネクター Expand section "4. MongoDB の Debezium コネクター" Collapse section "4. MongoDB の Debezium コネクター" 4.1. Debezium MongoDB コネクターの概要 4.2. Debezium MongoDB コネクターの仕組み Expand section "4.2. Debezium MongoDB コネクターの仕組み" Collapse section "4.2. Debezium MongoDB コネクターの仕組み" 4.2.1. Debezium コネクターでサポートされる MongoDB トポロジー 4.2.2. Debezium MongoDB コネクターでレプリカセットおよびシャードクラスターに論理名を使用する方法 4.2.3. Debezium MongoDB コネクターでのスナップショットの実行方法 4.2.4. Debezium MongoDB コネクターでの変更イベントレコードのストリーミング方法 4.2.5. Debezium MongoDB 変更イベントレコードを受信する Kafka トピックのデフォルト名 4.2.6. イベントキーが Debezium MongoDB コネクターのトピックパーティション設定を制御する方法 4.2.7. トランザクション境界を表す Debezium MongoDB コネクターによって生成されたイベント 4.3. Debezium MongoDB コネクターのデータ変更イベントの説明 Expand section "4.3. Debezium MongoDB コネクターのデータ変更イベントの説明" Collapse section "4.3. Debezium MongoDB コネクターのデータ変更イベントの説明" 4.3.1. Debezium MongoDB 変更イベントのキー 4.3.2. Debezium MongoDB 変更イベントの値 4.4. Debezium コネクターと連携する MongoDB の設定 4.5. Debezium MongoDB コネクターのデプロイメント Expand section "4.5. Debezium MongoDB コネクターのデプロイメント" Collapse section "4.5. Debezium MongoDB コネクターのデプロイメント" 4.5.1. AMQ Streams を使用した MongoDB コネクターデプロイメント 4.5.2. AMQ Streams を使用した Debezium MongoDB コネクターのデプロイ 4.5.3. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium MongoDB コネクターのデプロイ 4.5.4. Debezium MongoDB コネクターが実行していることの確認 4.5.5. Debezium Db2 コネクター設定プロパティーの説明 4.6. Debezium MongoDB コネクターのパフォーマンスの監視 Expand section "4.6. Debezium MongoDB コネクターのパフォーマンスの監視" Collapse section "4.6. Debezium MongoDB コネクターのパフォーマンスの監視" 4.6.1. MongoDB スナップショット作成中の Debezium の監視 4.6.2. Debezium MongoDB コネクターレコードストリーミングの監視 4.7. Debezium MongoDB コネクターによる障害および問題の処理方法 5. MySQL の Debezium コネクター Expand section "5. MySQL の Debezium コネクター" Collapse section "5. MySQL の Debezium コネクター" 5.1. Debezium MySQL コネクターの仕組み Expand section "5.1. Debezium MySQL コネクターの仕組み" Collapse section "5.1. Debezium MySQL コネクターの仕組み" 5.1.1. Debezium コネクターでサポートされる MySQL トポロジー 5.1.2. Debezium MySQL コネクターによるデータベーススキーマの変更の処理方法 5.1.3. Debezium MySQL コネクターによるデータベーススキーマの変更の公開方法 5.1.4. Debezium MySQL コネクターによるデータベーススナップショットの実行方法 Expand section "5.1.4. Debezium MySQL コネクターによるデータベーススナップショットの実行方法" Collapse section "5.1.4. Debezium MySQL コネクターによるデータベーススナップショットの実行方法" 5.1.4.1. アドホックスナップショット 5.1.4.2. 増分スナップショット 5.1.5. Debezium MySQL 変更イベントレコードを受信する Kafka トピックのデフォルト名 5.2. Debezium MySQL コネクターのデータ変更イベントの説明 Expand section "5.2. Debezium MySQL コネクターのデータ変更イベントの説明" Collapse section "5.2. Debezium MySQL コネクターのデータ変更イベントの説明" 5.2.1. Debezium MySQL 変更イベントのキー 5.2.2. Debezium MySQL 変更イベントの値 5.3. Debezium MySQL コネクターによるデータ型のマッピング方法 5.4. Debezium コネクターを実行するための MySQL の設定 Expand section "5.4. Debezium コネクターを実行するための MySQL の設定" Collapse section "5.4. Debezium コネクターを実行するための MySQL の設定" 5.4.1. Debezium コネクターの MySQL ユーザーの作成 5.4.2. Debezium の MySQL binlog の有効化 5.4.3. Debezium の MySQL グローバルトランザクション識別子の有効化 5.4.4. Debezium の MySQL セッションタイムアウトの設定 5.4.5. Debezium MySQL コネクターのクエリーログイベントの有効化 5.5. Debezium MySQL コネクターのデプロイメント Expand section "5.5. Debezium MySQL コネクターのデプロイメント" Collapse section "5.5. Debezium MySQL コネクターのデプロイメント" 5.5.1. AMQ Streams を使用した MySQL コネクターデプロイメント 5.5.2. AMQ Streams を使用した Debezium MySQL コネクターのデプロイ 5.5.3. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium MySQL コネクターのデプロイ 5.5.4. Debezium MySQL コネクターが実行していることの確認 5.5.5. Debezium MySQL コネクター設定プロパティーの説明 5.6. Debezium MySQL コネクターのパフォーマンスの監視 Expand section "5.6. Debezium MySQL コネクターのパフォーマンスの監視" Collapse section "5.6. Debezium MySQL コネクターのパフォーマンスの監視" 5.6.1. MySQL データベースのスナップショット作成時の Debezium の監視 5.6.2. Debezium MySQL コネクターレコードストリーミングの監視 5.6.3. Debezium MySQL コネクターのスキーマ履歴の監視 5.7. Debezium MySQL コネクターによる障害および問題の処理方法 6. Oracle 向けの Debezium コネクター (テクノロジープレビュー) Expand section "6. Oracle 向けの Debezium コネクター (テクノロジープレビュー)" Collapse section "6. Oracle 向けの Debezium コネクター (テクノロジープレビュー)" 6.1. Debezium Oracle コネクターの仕組み Expand section "6.1. Debezium Oracle コネクターの仕組み" Collapse section "6.1. Debezium Oracle コネクターの仕組み" 6.1.1. Debezium Oracle コネクターによるデータベーススナップショットの実行方法 Expand section "6.1.1. Debezium Oracle コネクターによるデータベーススナップショットの実行方法" Collapse section "6.1.1. Debezium Oracle コネクターによるデータベーススナップショットの実行方法" 6.1.1.1. アドホックスナップショット 6.1.1.2. 増分スナップショット 6.1.2. Debezium Oracle 変更イベントレコードを受信する Kafka トピックのデフォルト名 6.1.3. Debezium Oracle コネクターによるデータベーススキーマの変更の公開方法 6.1.4. トランザクション境界を表す Debezium Oracle コネクターによって生成されたイベント Expand section "6.1.4. トランザクション境界を表す Debezium Oracle コネクターによって生成されたイベント" Collapse section "6.1.4. トランザクション境界を表す Debezium Oracle コネクターによって生成されたイベント" 6.1.4.1. 変更データイベントのエンリッチメント 6.1.5. Oracle SCN 値間のギャップ 6.2. Debezium Oracle コネクターのデータ変更イベントの説明 Expand section "6.2. Debezium Oracle コネクターのデータ変更イベントの説明" Collapse section "6.2. Debezium Oracle コネクターのデータ変更イベントの説明" 6.2.1. Debezium Oracle コネクター変更イベントのキー 6.2.2. Debezium Oracle 変更イベントの値 6.3. Debezium Oracle コネクターによるデータ型のマッピング方法 6.4. Debezium と連携させるための Oracle の設定 Expand section "6.4. Debezium と連携させるための Oracle の設定" Collapse section "6.4. Debezium と連携させるための Oracle の設定" 6.4.1. Debezium で使用する Oracle データベースの準備 6.4.2. ログサイジングのやり直し 6.4.3. Debezium Oracle コネクターの Oracle ユーザーの作成 6.5. Debezium Oracle コネクターのデプロイメント Expand section "6.5. Debezium Oracle コネクターのデプロイメント" Collapse section "6.5. Debezium Oracle コネクターのデプロイメント" 6.5.1. AMQ Streams を使用した Debezium Oracle コネクターのデプロイメント 6.5.2. AMQ Streams を使用した Debezium Oracle コネクターのデプロイ 6.5.3. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium Oracle コネクターのデプロイ 6.5.4. Oracle JDBC ドライバーの取得 6.5.5. コンテナーデータベースとノンコンテナーデータベースの設定 6.5.6. Debezium Oracle コネクターが実行していることの確認 6.6. Debezium Oracle コネクター設定プロパティーの説明 6.7. Debezium Oracle コネクターのパフォーマンスの監視 Expand section "6.7. Debezium Oracle コネクターのパフォーマンスの監視" Collapse section "6.7. Debezium Oracle コネクターのパフォーマンスの監視" 6.7.1. Debezium SQL Server コネクターのスナップショットメトリクス 6.7.2. Debezium Oracle コネクターのストリーミングメトリクス 6.7.3. Debezium Oracle コネクターのスキーマ履歴メトリクス 6.8. Debezium Oracle コネクターによる障害および問題の処理方法 7. PostgreSQL の Debezium コネクター Expand section "7. PostgreSQL の Debezium コネクター" Collapse section "7. PostgreSQL の Debezium コネクター" 7.1. Debezium PostgreSQL コネクターの概要 7.2. Debezium PostgreSQL コネクターの仕組み Expand section "7.2. Debezium PostgreSQL コネクターの仕組み" Collapse section "7.2. Debezium PostgreSQL コネクターの仕組み" 7.2.1. PostgreSQL コネクターのセキュリティー 7.2.2. Debezium PostgreSQL コネクターによるデータベーススナップショットの実行方法 Expand section "7.2.2. Debezium PostgreSQL コネクターによるデータベーススナップショットの実行方法" Collapse section "7.2.2. Debezium PostgreSQL コネクターによるデータベーススナップショットの実行方法" 7.2.2.1. アドホックスナップショット 7.2.2.2. 増分スナップショット 7.2.3. Debezium PostgreSQL コネクターによる変更イベントレコードのストリーミング方法 7.2.4. Debezium PostgreSQL の変更イベントレコードを受信する Kafka トピックのデフォルト名 7.2.5. Debezium PostgreSQL 変更イベントレコードのメタデータ 7.2.6. トランザクション境界を表す Debezium PostgreSQL コネクターによって生成されたイベント 7.3. Debezium PostgreSQL コネクターのデータ変更イベントの説明 Expand section "7.3. Debezium PostgreSQL コネクターのデータ変更イベントの説明" Collapse section "7.3. Debezium PostgreSQL コネクターのデータ変更イベントの説明" 7.3.1. Debezium PostgreSQL の変更イベントのキー 7.3.2. Debezium PostgreSQL 変更イベントの値 7.4. Debezium PostgreSQL コネクターによるデータ型のマッピング方法 7.5. Debezium コネクターを実行するための PostgreSQL の設定 Expand section "7.5. Debezium コネクターを実行するための PostgreSQL の設定" Collapse section "7.5. Debezium コネクターを実行するための PostgreSQL の設定" 7.5.1. Debezium pgoutput プラグインのレプリケーションスロットの設定 7.5.2. Debezium コネクターの PostgreSQL パーミッションの設定 7.5.3. Debezium が PostgreSQL パブリケーションを作成できるように権限を設定 7.5.4. Debezium コネクターホストでのレプリケーションを許可するように PostgreSQL を設定 7.5.5. Debezium WAL ディスク領域の消費を管理するための PostgreSQL の設定 7.6. Debezium PostgreSQL コネクターのデプロイメント Expand section "7.6. Debezium PostgreSQL コネクターのデプロイメント" Collapse section "7.6. Debezium PostgreSQL コネクターのデプロイメント" 7.6.1. AMQ Streams を使用した PostgreSQL コネクターデプロイメント 7.6.2. AMQ Streams を使用した Debezium PostgreSQL コネクターのデプロイ 7.6.3. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium PostgreSQL コネクターのデプロイ 7.6.4. Debezium PostgreSQL コネクターが実行していることの確認 7.6.5. Debezium PostgreSQL コネクター設定プロパティーの説明 7.7. Debezium PostgreSQL コネクターのパフォーマンスの監視 Expand section "7.7. Debezium PostgreSQL コネクターのパフォーマンスの監視" Collapse section "7.7. Debezium PostgreSQL コネクターのパフォーマンスの監視" 7.7.1. PostgreSQL データベースのスナップショット作成時の Debezium の監視 7.7.2. Debezium PostgreSQL コネクターレコードストリーミングの監視 7.8. Debezium PostgreSQL コネクターによる障害および問題の処理方法 8. SQL Server の Debezium コネクター Expand section "8. SQL Server の Debezium コネクター" Collapse section "8. SQL Server の Debezium コネクター" 8.1. Debezium SQL Server コネクターの概要 8.2. Debezium SQL Server コネクターの仕組み Expand section "8.2. Debezium SQL Server コネクターの仕組み" Collapse section "8.2. Debezium SQL Server コネクターの仕組み" 8.2.1. Debezium SQL Sever コネクターによるデータベーススナップショットの実行方法 Expand section "8.2.1. Debezium SQL Sever コネクターによるデータベーススナップショットの実行方法" Collapse section "8.2.1. Debezium SQL Sever コネクターによるデータベーススナップショットの実行方法" 8.2.1.1. アドホックスナップショット 8.2.1.2. 増分スナップショット 8.2.2. Debezium SQL Server コネクターによる変更データテーブルの読み取り方法 8.2.3. Debezium SQL Server 変更イベントレコードを受信する Kafka トピックのデフォルト名 8.2.4. Debezium SQL Server コネクターによるスキーマ変更トピックの使用方法 8.2.5. Debezium SQL Server コネクターのデータ変更イベントの説明 Expand section "8.2.5. Debezium SQL Server コネクターのデータ変更イベントの説明" Collapse section "8.2.5. Debezium SQL Server コネクターのデータ変更イベントの説明" 8.2.5.1. Debezium SQL Server 変更イベントのキー 8.2.5.2. Debezium SQL Server 変更イベントの値 8.2.6. トランザクション境界を表す Debezium SQL Server コネクターによって生成されたイベント Expand section "8.2.6. トランザクション境界を表す Debezium SQL Server コネクターによって生成されたイベント" Collapse section "8.2.6. トランザクション境界を表す Debezium SQL Server コネクターによって生成されたイベント" 8.2.6.1. 変更データイベントのエンリッチメント 8.2.7. Debezium SQL Server コネクターによるデータ型のマッピング方法 8.3. Debezium コネクターを実行するための SQL Server のセットアップ Expand section "8.3. Debezium コネクターを実行するための SQL Server のセットアップ" Collapse section "8.3. Debezium コネクターを実行するための SQL Server のセットアップ" 8.3.1. SQL Server データベースでの CDC の有効化 8.3.2. SQL Server テーブルでの CDC の有効化 8.3.3. ユーザーが CDC テーブルにアクセスできることの確認 8.3.4. Azure 上の SQL Server 8.3.5. SQL Server キャプチャージョブエージェント設定のサーバー負荷およびレイテンシーへの影響 8.3.6. SQL Server のキャプチャージョブエージェントの設定パラメーター 8.4. Debezium SQL Server コネクターのデプロイ Expand section "8.4. Debezium SQL Server コネクターのデプロイ" Collapse section "8.4. Debezium SQL Server コネクターのデプロイ" 8.4.1. AMQ Streams を使用した SQL Server コネクターデプロイメント 8.4.2. AMQ Streams を使用した Debezium SQL Server コネクターのデプロイ 8.4.3. Dockerfile からカスタム Kafka Connect コンテナーイメージをビルドして Debezium SQL Server コネクターのデプロイ 8.4.4. Debezium SQL Server コネクター設定プロパティーの説明 8.5. スキーマ変更後のキャプチャーテーブルの更新 Expand section "8.5. スキーマ変更後のキャプチャーテーブルの更新" Collapse section "8.5. スキーマ変更後のキャプチャーテーブルの更新" 8.5.1. スキーマの変更後のオフライン更新の実行 8.5.2. スキーマの変更後のオンライン更新の実行 8.6. Debezium SQL Server コネクターのパフォーマンスの監視 Expand section "8.6. Debezium SQL Server コネクターのパフォーマンスの監視" Collapse section "8.6. Debezium SQL Server コネクターのパフォーマンスの監視" 8.6.1. Debezium SQL Server コネクターのスナップショットメトリクス 8.6.2. Debezium SQL Server コネクターのストリーミングメトリクス 8.6.3. Debezium SQL Server コネクターのスキーマ履歴メトリクス 9. Debezium の監視 Expand section "9. Debezium の監視" Collapse section "9. Debezium の監視" 9.1. Debezium コネクターを監視するためのメトリクス 9.2. ローカルインストールでの JMX の有効化 Expand section "9.2. ローカルインストールでの JMX の有効化" Collapse section "9.2. ローカルインストールでの JMX の有効化" 9.2.1. Zookeeper JMX 環境変数 9.2.2. Kafka JMX 環境変数 9.2.3. Kafka Connect JMX 環境変数 9.3. OpenShift 上での Debezium の監視 10. Debezium のログ機能 Expand section "10. Debezium のログ機能" Collapse section "10. Debezium のログ機能" 10.1. Debezium ログの概念 10.2. デフォルトの Debezium ログ設定 10.3. Debezium ログの設定 Expand section "10.3. Debezium ログの設定" Collapse section "10.3. Debezium ログの設定" 10.3.1. ロガーを設定して Debezium のログレベルを変更する 10.3.2. Kafka Connect API を使用して Debezium のログレベルを動的に変更する 10.3.3. マッピングされた診断コンテキストを追加して Debezium のロギングレベルの変更 10.4. OpenShift での Debezium ログ 11. アプリケーション用 Debezium コネクターの設定 Expand section "11. アプリケーション用 Debezium コネクターの設定" Collapse section "11. アプリケーション用 Debezium コネクターの設定" 11.1. Kafka Connect 自動トピック作成のカスタマイズ Expand section "11.1. Kafka Connect 自動トピック作成のカスタマイズ" Collapse section "11.1. Kafka Connect 自動トピック作成のカスタマイズ" 11.1.1. Kafka ブローカーの自動トピック作成の無効化 11.1.2. Kafka Connect の自動トピック作成の設定 11.1.3. 自動的に作成されたトピックの設定 Expand section "11.1.3. 自動的に作成されたトピックの設定" Collapse section "11.1.3. 自動的に作成されたトピックの設定" 11.1.3.1. トピック作成グループ 11.1.3.2. トピック作成グループの設定プロパティー 11.1.3.3. Debezium デフォルトトピック作成グループ設定の指定 11.1.3.4. Debezium カスタムトピック作成グループ設定の指定 11.1.3.5. Debezium カスタムトピック作成グループの登録 11.2. Avro シリアライゼーションを使用する Debezium コネクターの設定 Expand section "11.2. Avro シリアライゼーションを使用する Debezium コネクターの設定" Collapse section "11.2. Avro シリアライゼーションを使用する Debezium コネクターの設定" 11.2.1. Service Registry の概要 11.2.2. Avro シリアライゼーションを使用する Debezium コネクターのデプロイの概要 11.2.3. Debezium コンテナーで Avro を使用するコネクターのデプロイ 11.2.4. Avro の名前の要件について 11.3. CloudEvents フォーマットでの Debezium 変更イベントレコードの出力 Expand section "11.3. CloudEvents フォーマットでの Debezium 変更イベントレコードの出力" Collapse section "11.3. CloudEvents フォーマットでの Debezium 変更イベントレコードの出力" 11.3.1. CloudEvents フォーマットでの Debezium 変更イベントレコードの例 11.3.2. Debezium CloudEvents コンバーターの設定例 11.3.3. Debezium CloudEvents コンバーター設定オプション 11.4. Debezium コネクターへのシグナル送信 Expand section "11.4. Debezium コネクターへのシグナル送信" Collapse section "11.4. Debezium コネクターへのシグナル送信" 11.4.1. Debezium シグナリングの有効化 Expand section "11.4.1. Debezium シグナリングの有効化" Collapse section "11.4.1. Debezium シグナリングの有効化" 11.4.1.1. デベージアムシグナリングデータ収集の必須構造 11.4.1.2. Debezium シグナルのデータコレクションの作成 11.4.2. デベージアムシグナルアクションの種類 Expand section "11.4.2. デベージアムシグナルアクションの種類" Collapse section "11.4.2. デベージアムシグナルアクションの種類" 11.4.2.1. ロギング信号 11.4.2.2. アドホックなスナップショット信号 11.4.2.3. 増分スナップショット 12. Apache Kafka で交換されたメッセージを修正するためのトランスフォームの適用 Expand section "12. Apache Kafka で交換されたメッセージを修正するためのトランスフォームの適用" Collapse section "12. Apache Kafka で交換されたメッセージを修正するためのトランスフォームの適用" 12.1. SMT 述語を使用した変換の選択的適用 Expand section "12.1. SMT 述語を使用した変換の選択的適用" Collapse section "12.1. SMT 述語を使用した変換の選択的適用" 12.1.1. SMT 述語について 12.1.2. SMT 述語の定義 12.1.3. 廃棄 (tombstone) イベントの無視 12.2. 指定したトピックへの Debezium イベントレコードのルーティング Expand section "12.2. 指定したトピックへの Debezium イベントレコードのルーティング" Collapse section "12.2. 指定したトピックへの Debezium イベントレコードのルーティング" 12.2.1. 指定したトピックに Debezium レコードをルーティングするユースケース 12.2.2. 複数テーブルの Debezium レコードを 1 つのトピックにルーティングする例 12.2.3. 同一トピックにルーティングされる Debezium レコード間でのキーの一意性確保 12.2.4. トピックルーティング変換を一部適用するオプション 12.2.5. Debezium トピックルーティング変換設定用のオプション 12.3. イベントの内容に応じた変更イベントレコードのトピックへのルーティング Expand section "12.3. イベントの内容に応じた変更イベントレコードのトピックへのルーティング" Collapse section "12.3. イベントの内容に応じた変更イベントレコードのトピックへのルーティング" 12.3.1. Debezium コンテンツベースのルーティング SMT の設定 12.3.2. 以下に例を示します。Debezium コンテンツベースルーティングの基本設定 12.3.3. Debezium コンテンツベースルーティングの式で使用される変数 12.3.4. コンテンツベースのルーティング変換を一部適用するオプション 12.3.5. 他のスクリプト言語によるコンテンツベースのルーティング条件の設定 12.3.6. コンテンツベースのルーティング変換設定用のオプション 12.4. Debezium 変更イベントレコードの絞り込み Expand section "12.4. Debezium 変更イベントレコードの絞り込み" Collapse section "12.4. Debezium 変更イベントレコードの絞り込み" 12.4.1. Debezium フィルター SMT の設定 12.4.2. 以下に例を示します。Debezium ベーシックフィルターの SMT 設定 12.4.3. フィルターの式で使用される変数 12.4.4. フィルター変換を一部適用するオプション 12.4.5. 他のスクリプト言語によるフィルター条件の設定 12.4.6. フィルター変換設定用のオプション 12.5. Debezium の変更イベントからステート after ソースレコードを抽出する Expand section "12.5. Debezium の変更イベントからステート after ソースレコードを抽出する" Collapse section "12.5. Debezium の変更イベントからステート after ソースレコードを抽出する" 12.5.1. Debezium 変更イベントの構造について 12.5.2. Debezium イベントフラット化変換の動作 12.5.3. Debezium イベントフラット化変換の設定 12.5.4. Kafka レコードに Debezium メタデータを追加する例 12.5.5. イベントフラット化変換を選択的に適用するオプション 12.5.6. Debezium イベントフラット化変換設定用のオプション 12.6. 送信トレイパターンを使用する Debezium コネクターの設定 Expand section "12.6. 送信トレイパターンを使用する Debezium コネクターの設定" Collapse section "12.6. 送信トレイパターンを使用する Debezium コネクターの設定" 12.6.1. Debezium 送信トレイメッセージの例 12.6.2. Debezium 送信トレイイベントルーター SMT が要求する送信トレイテーブルの構造 12.6.3. Debezium 送信トレイイベントルーター SMT の基本設定 12.6.4. 送信トレイイベントルーター変換を選択的に適用するオプション 12.6.5. Debezium 送信トレイメッセージでのペイロードフォーマットとしての Avro の使用 12.6.6. Debezium 送信トレイメッセージへの追加フィールドの出力 12.6.7. JSON としてエスケープされた JSON 文字列の拡張 12.6.8. 送信トレイイベントルーター変換設定用のオプション 12.7. 送信トレイパターンを使用する Debezium MongoDB コネクターの設定 Expand section "12.7. 送信トレイパターンを使用する Debezium MongoDB コネクターの設定" Collapse section "12.7. 送信トレイパターンを使用する Debezium MongoDB コネクターの設定" 12.7.1. Debezium MongoDB 送信トレイメッセージの例 12.7.2. Debezium mongodb 送信トレイイベントルーター SMT が要求する送信トレイコレクションの構造 12.7.3. 基本的な Debezium MongoDB 送信トレイイベントルーター SMT 設定 12.7.4. MongoDB 送信トレイイベントルーター変換を選択的に適用するオプション 12.7.5. Debezium MongoDB 送信トレイメッセージでペイロードフォーマットとして Avro を使用 12.7.6. Debezium MongoDB 送信トレイメッセージへの追加フィールドの出力 12.7.7. JSON としてエスケープされた JSON 文字列の拡張 12.7.8. 送信トレイイベントルーター変換設定用のオプション Settings Close Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF Language and Page Formatting Options Language: 日本語 English Language: 日本語 English Format: Multi-page Single-page PDF Format: Multi-page Single-page PDF 10.4. OpenShift での Debezium ログ OpenShift で Debezium を使用している場合、Kafka Connect ロガーを使用して Debezium ロガーおよびログレベルを設定することができます。Kafka Connect スキーマでのロギングプロパティーの設定に関する詳細は、Using AMQ Streams on OpenShiftを参照してください。 Previous Next