Deep-dive on the Next Gen Platform. Join the Webinar!

Skip Navigation
Show nav
Dev Center
  • Get Started
  • ドキュメント
  • Changelog
  • Search
  • Get Started
    • Node.js
    • Ruby on Rails
    • Ruby
    • Python
    • Java
    • PHP
    • Go
    • Scala
    • Clojure
    • .NET
  • ドキュメント
  • Changelog
  • More
    Additional Resources
    • Home
    • Elements
    • Products
    • Pricing
    • Careers
    • Help
    • Status
    • Events
    • Podcasts
    • Compliance Center
    Heroku Blog

    Heroku Blog

    Find out what's new with Heroku on our blog.

    Visit Blog
  • Log inorSign up
Hide categories

Categories

  • Heroku のアーキテクチャ
    • Dyno (アプリコンテナ)
      • Dyno Management
      • Dyno Concepts
      • Dyno Behavior
      • Dyno Reference
      • Dyno Troubleshooting
    • スタック (オペレーティングシステムイメージ)
    • ネットワーキングと DNS
    • プラットフォームポリシー
    • プラットフォームの原則
  • Developer Tools
    • コマンドライン
    • Heroku VS Code Extension
  • デプロイ
    • Git を使用したデプロイ
    • Docker によるデプロイ
    • デプロイ統合
  • 継続的デリバリーとインテグレーション
    • 継続的統合
  • 言語サポート
    • Node.js
      • Working with Node.js
      • Troubleshooting Node.js Apps
      • Node.js Behavior in Heroku
    • Ruby
      • Rails のサポート
      • Bundler の使用
      • Working with Ruby
      • Ruby Behavior in Heroku
      • Troubleshooting Ruby Apps
    • Python
      • Working with Python
      • Python でのバックグランドジョブ
      • Python Behavior in Heroku
      • Django の使用
    • Java
      • Java Behavior in Heroku
      • Working with Java
      • Maven の使用
      • Spring Boot の使用
      • Troubleshooting Java Apps
    • PHP
      • PHP Behavior in Heroku
      • Working with PHP
    • Go
      • Go の依存関係管理
    • Scala
    • Clojure
    • .NET
      • Working with .NET
  • データベースとデータ管理
    • Heroku Postgres
      • Postgres の基礎
      • Postgres スターターガイド
      • Postgres のパフォーマンス
      • Postgres のデータ転送と保持
      • Postgres の可用性
      • Postgres の特別なトピック
      • Migrating to Heroku Postgres
    • Heroku Data For Redis
    • Apache Kafka on Heroku
    • その他のデータストア
  • AI
    • Working with AI
  • モニタリングとメトリクス
    • ログ記録
  • アプリのパフォーマンス
  • アドオン
    • すべてのアドオン
  • 共同作業
  • セキュリティ
    • アプリのセキュリティ
    • ID と認証
      • シングルサインオン (SSO)
    • Private Space
      • インフラストラクチャネットワーキング
    • コンプライアンス
  • Heroku Enterprise
    • Enterprise Accounts
    • Enterprise Team
    • Heroku Connect (Salesforce 同期)
      • Heroku Connect の管理
      • Heroku Connect のリファレンス
      • Heroku Connect のトラブルシューティング
  • パターンとベストプラクティス
  • Heroku の拡張
    • Platform API
    • アプリの Webhook
    • Heroku Labs
    • アドオンのビルド
      • アドオン開発のタスク
      • アドオン API
      • アドオンのガイドラインと要件
    • CLI プラグインのビルド
    • 開発ビルドパック
    • Dev Center
  • アカウントと請求
  • トラブルシューティングとサポート
  • Salesforce とのインテグレーション
  • データベースとデータ管理
  • Heroku ストリーミングデータコネクターのベストプラクティス

Heroku ストリーミングデータコネクターのベストプラクティス

日本語 — Switch to English

最終更新日 2024年04月24日(水)

Table of Contents

  • 役に立つ記事
  • 注意事項

この記事では、ストリーミングデータコネクター​運用のベストプラクティスに関連したいくつかの注意事項について説明します。この統合は Apache Kafka Connect および Debezium によってサポートされているため、設定オプションについての説明箇所ではこれらのコンポーネントについて言及します。

役に立つ記事

困ったときは​ (Debezium)

注意事項

作成

  • Debezium は UTF-8 データベースでのみ動作します。別のエンコードを使用している場合は、Heroku ストリーミングデータコネクターを有効にする前にエンコードを UTF-8 に変更します。コネクターが作成された後に別のエンコードに変更した場合、コネクターはイベントの処理を中止します。
  • 新しいコネクターが作成されると、それは Postgres データベースに接続します。このプロセスはコストの高い操作である可能性があり、ソースの Postgres データベースとターゲットの Kafka クラスターの両方で負荷を増加させる可能性があります。テーブルと列を適切に選択するように注意する必要があります。詳細は、ドキュメント​を参照してください。

使用法

  • CDC イベントの “before” データが入力されるのは、テーブルの中で REPLICA IDENTITY​ に含まれる部分だけです。つまり、ほとんどの場合、デフォルトでは主キーのみが “before” データに反映されます。詳細は、ドキュメント​を参照してください。
  • 主キーに変更を加えるときは、スキーマ情報に問題が生じないよう、慎重に調整する必要があります。詳細は、ドキュメント​を参照してください。
  • CDC イベントは最低 1 回​は配信されるよう設計されています。冗長な CDC イベントを適切に処理するように、Kafka コンシューマーをビルドおよび設定する必要があります。不具合が発生した場合は、さらに多くのイベントが表示されることがあります。重複したイベントについての詳細は、Debezium の FAQ​ にある「Why must consuming applications expect duplicate events?​」(消費側のアプリケーションで重複したイベントを予測する必要があるのはなぜですか?) を参照してください。
  • UPDATE​ イベントの際、変更のない TOAST 値にはプレースホルダー __debezium_unavailable_value​ があります。この値を考慮に入れておかないと、実際の値であるかのようにプレースホルダーを使用してしまいます。詳細はドキュメント​をご覧ください。
  • 大量のデータを含むデータベース行から Kafka メッセージを生成する場合、トピックの最大メッセージサイズ (デフォルト: 1 MB) を超えるメッセージは生成できません。これらの変更は (内部で) ログに記録されますが、イベントは生成されません (暗黙的に処理されます)。
  • Kafka トピックは、1 つ以上のパーティションで作成されます。その結果、消費されるときに変更イベントは完全なグローバルな順序付けがされません​。特定の行の変更イベントは、完全に順序付けされています。順序付けについての詳細は、Debezium の FAQ​ にある「How are events for a database organized?​」(データベースのイベントはどのように構成されていますか?) を参照してください。

障害

  • コネクターがレプリケーションを停止した場合、コネクターの進行状況を追跡するレプリケーションスロットは WAL (ログ先行書き込み) が削除されるのを防ぎます。Postgres データベースで WAL 用のディスク領域が不足した場合、データベースは完全に停止します。詳細はドキュメント​をご覧ください。
  • さまざまな理由で障害が発生し、コネクターの停止に至る可能性があります。たとえば、ネットワークパーティション、AWS の問題、Kafka Connect または Debezium のバグ、Heroku のコントロールプレーンの問題などが考えられます。データベースのレプリケーションスロット​を監視し、これらの状況の有無を確認することは重要です。
  • 特定の障害モードでは、データベースの安定運用を維持するためにレプリケーションスロットを削除します。条件がクリアされ、レプリケーションスロットが再び作成されると、コネクターは新しいレプリケーションスロットを作成し、そのリカバリポイントからイベントの発行を開始します。データベースが停止する前に Kafka にストリーミングされなかった変更イベントは失われます。

一時停止したコネクター

  • コネクターを「一時停止」状態にしたまま数時間放置しないでください。一時停止したコネクターによって WAL が削除されず、それによってプライマリデータベースにリスクが生じる可能性があります。コネクターを長期間一時停止したままにするよりは、破棄することをお勧めします。
  • コネクターが一時停止中に発生した変更イベントは、Kafka に送達されることが保証されません​。フェイルオーバーが発生した場合 (システム障害または定期的なメンテナンスによる)、コネクターの一時停止後の変更イベントは失われます。

破棄

  • テーブルを削除すると、対応する Kafka トピックはツームストーン状態になりますが、破棄されるわけではありません。
  • コネクターのプロビジョニングを解除しても、関連付けられた Kafka トピックのプロビジョニングは自動的に解除されません。このデータを削除したい場合は、CLI を使用して heroku kafka:topics:destroy <topic_name> --app <app_name>​ を実行して、これらのトピックを手動で削除する必要があります。詳細はドキュメント​をご覧ください。

関連カテゴリー

  • データベースとデータ管理
MuleSoft への Heroku データサービスの接続 Heroku mTLS プラグインの CLI コマンド

Information & Support

  • Getting Started
  • Documentation
  • Changelog
  • Compliance Center
  • Training & Education
  • Blog
  • Support Channels
  • Status

Language Reference

  • Node.js
  • Ruby
  • Java
  • PHP
  • Python
  • Go
  • Scala
  • Clojure
  • .NET

Other Resources

  • Careers
  • Elements
  • Products
  • Pricing
  • RSS
    • Dev Center Articles
    • Dev Center Changelog
    • Heroku Blog
    • Heroku News Blog
    • Heroku Engineering Blog
  • Twitter
    • Dev Center Articles
    • Dev Center Changelog
    • Heroku
    • Heroku Status
  • Github
  • LinkedIn
  • © 2025 Salesforce, Inc. All rights reserved. Various trademarks held by their respective owners. Salesforce Tower, 415 Mission Street, 3rd Floor, San Francisco, CA 94105, United States
  • heroku.com
  • Legal
  • Terms of Service
  • Privacy Information
  • Responsible Disclosure
  • Trust
  • Contact
  • Cookie Preferences
  • Your Privacy Choices