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
View 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
      • Node.js Behavior in Heroku
      • Troubleshooting Node.js Apps
    • 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
    • Heroku Inference
      • Inference API
      • Quick Start Guides
      • AI Models
      • Inference Essentials
    • Vector Database
    • Model Context Protocol
  • モニタリングとメトリクス
    • ログ記録
  • アプリのパフォーマンス
  • アドオン
    • すべてのアドオン
  • 共同作業
  • セキュリティ
    • アプリのセキュリティ
    • 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 とのインテグレーション
  • データベースとデータ管理
  • Apache Kafka on Heroku
  • Apache Kafka on Heroku アドオンの移行

Apache Kafka on Heroku アドオンの移行

日本語 — Switch to English

最終更新日 2022年12月13日(火)

Table of Contents

  • Kafka アドオン間の移行が必要になる場合
  • 移行を処理する方法
  • メンテナンスウィンドウの間にアドオン間で移行する方法
  • メンテナンスウィンドウに入ることなくアドオン間で移行する方法

Apache Kafka on Heroku​ のプランレベル間のスケールアップまたはスケールダウンは通常、シームレスであり、その場で実行されます。ただし、実際のデータ移行が必要になる状況がいくつか存在します。このドキュメントでは、これらの条件と適用可能なプロセスの概要を示します。

Kafka アドオン間の移行が必要になる場合

Kafka アドオン間の移行が必要になるケースには、次の 3 つがあります。

  • マルチテナント Kafka (Kafka Basic)​) アドオンを使用しており、専用 Kafka​ アドオンの使用を開始したい。
  • 専用 Kafka​ アドオンを使用しており、マルチテナント Kafka (Kafka Basic)​) アドオンの使用を開始したい。
  • ベータ版のマルチテナント Kafka (Kafka Basic)​) アドオンを使用しており、そのアドオンをホストするクラスターがサポートの終了に近づいている。

移行を処理する方法

多くのシナリオでは、アプリケーションがメンテナンスウィンドウに入り、アプリケーションのコードを変更することなく新しいアドオンに移行できます。一般には、移行の複雑さが大幅に削減され、アプリの大きな変更が必要ないため、可能であればメンテナンスウィンドウに入ることをお勧めします。

アプリケーションがメンテナンスウィンドウに入ることができない場合は、トピックの両方のセットに二重に書き込み、新しいアドオンが保持期間より長い期間にわたって書き込みを受信した後に古いアドオンから新しいアドオンにカットオーバーすることによって新しいアドオンに移行する必要があります。

メンテナンスウィンドウの間にアドオン間で移行する方法

メンテナンスウィンドウの間に移行するための高レベルの手順は次のとおりです。

  1. 関連するすべてのトピックとコンシューマーグループを使用して新しいアドオンをプロビジョニングします。
  2. メンテナンスウィンドウに入ります。
  3. Kafka プロデューサーを停止します。
  4. Kafka コンシューマーが完全に追いつくまで待ちます。
  5. 新しいアドオンに切り替えます。
  6. Kafka プロデューサーおよびコンシューマーを起動します。
  7. メンテナンスウィンドウを終了します。
$ heroku addons:create heroku-kafka:basic-0 --as NEW_KAFKA -a mackerel
$ heroku kafka:topics:create my-topic-name NEW_KAFKA -a mackerel
$ heroku kafka:consumer-groups:create my-group-name KAFKA -a mackerel
$ heroku ps:scale producer=0 -a mackerel
# check consumers
heroku ps:scale consumer=0 -a mackerel
heroku maintenance:on -a mackerel
# kafka-parallel-2019
heroku addons:attach kafka-symmetrical-26061 --as OLD_KAFKA -a mackerel
$ heroku addons:attach kafka-parallel-2019 --as KAFKA -a mackerel
$ heroku ps:scale producer=1 consumer=1 -a mackerel
$ heroku addons:destroy kafka-symmetrical-26061 -a mackerel

メンテナンスウィンドウに入ることなくアドオン間で移行する方法

メンテナンスウィンドウに入ることなく移行するための高レベルの手順は次のとおりです。

  1. アプリでの二重書き込みを準備します。
  2. 関連するすべてのトピックとコンシューマーグループを使用して新しい Kafka アドオンをプロビジョニングします。
  3. 古いアドオンと新しいアドオンの両方に二重に書き込みます。
  4. 新しいアドオンに古いアドオンと同じ履歴データが含まれるまで待ちます。
  5. 古いアドオンへの生成を停止します。
  6. 古いアドオンを破棄します。

これらの手順についてはこのセクションでさらに詳細に説明します。

手順 1: アプリでの二重書き込みを準備する

アプリで、Kafka 環境設定の 2 つのセット (アドオンごとに 1 つ) がサポートされている必要があります。

この例では、二重書き込みが開始される前に​ KAFKA_URL​、KAFKA_CLIENT_CERT​、KAFKA_CLIENT_CERT_KEY​、KAFKA_TRUSTED_CERT​ を古い​ Kafka アドオンに使用し、二重書き込みが開始された後に​それらを新しい​ Kafka アドオンに使用します。

この例では、二重書き込みが開始された後に OLD_KAFKA_URL​、OLD_KAFKA_CLIENT_CERT​、OLD_KAFKA_CLIENT_CERT_KEY​、OLD_KAFKA_TRUSTED_CERT​ を古い​ Kafka アドオンに使用します。この環境設定のセットは、二重書き込みが実行されている間だけ存在します。

次の 2 つの追加の環境設定が必要です。これは、プロデューサーとコンシューマーに書き込みと読み取りの場所を指示します。

  • PRODUCER_ADDON_NAMES​ は、どのアドオンに書き込むかを検出するためにプロデューサーによって使用されます。
  • CONSUMER_ADDON_NAME​ は、どのアドオンから読み取るかを検出するためにコンシューマーによって使用されます。

アプリに次のサポートを追加する必要があります。

  • PRODUCER_ADDON_NAMES​ で指定されているすべてのアドオンへの生成
  • CONSUMER_ADDON_NAME​ で指定されているアドオンからの消費

コンシューマーは、重複したメッセージをべき等的に処理する必要があります。 詳細は、Apache Kafka Heroku の堅牢な使用法​に関する記事を参照してください。

手順 2: 新しいアドオンをプロビジョニングする

新しいアドオンをプロビジョニングする前に、準備として既存の Kafka アドオンを新しい名前でアタッチします。

$ heroku addons:attach kafka-symmetrical-26061 --as OLD_KAFKA -a mackerel
$ heroku addons:create heroku-kafka:basic-0 --as KAFKA -a mackerel

手順 3: 新しいアドオンでトピックとコンシューマーグループを作成する

古いアドオンからトピックとコンシューマーグループの一覧を取得します。

$ heroku kafka:topics OLD_KAFKA -a mackerel
$ heroku kafka:consumer-groups OLD_KAFKA -a mackerel

これで、新しいアドオンでこれらのトピックとコンシューマーグループを作成できます。

$ heroku kafka:topics:create my-topic-name KAFKA -a mackerel
$ heroku kafka:consumer-groups:create my-group-name KAFKA -a mackerel

手順 4: 古いアドオンと新しいアドオンに二重に書き込む

新しいアドオンのトピックがデータでいっぱいになるまでの間、アプリはトピックの両方のセットに生成し、古いアドオンのトピックから消費する必要があります。

$ heroku config:set PRODUCER_ADDON_NAMES=OLD_KAFKA,KAFKA -a mackerel
$ heroku config:set CONSUMER_ADDON_NAME=OLD_KAFKA -a mackerel

手順 5: 新しいアドオンに十分な履歴データが含まれるまで待つ

新しいアドオンが保持期間より長い期間にわたって書き込みを受信すると、両方のアドオンが同じデータを表すようになります。 これは、コンシューマーを古いアドオンから新しいアドオンに切り替えることができることを示します。

$ heroku config:set CONSUMER_ADDON_NAME=KAFKA -a mackerel

手順 6: 古いアドオンへの生成を停止する

新しいアドオンからの消費が適切に行われるようになったら、古いアドオンへの生成を停止できます。

$ heroku config:set PRODUCER_ADDON_NAMES=KAFKA -a mackerel

手順 7: 古いアドオンを破棄する

アプリが古いアドオンから消費しなくなっているため、このアドオンを安全に破棄できます。

$ heroku addons:destroy OLD_KAFKA_URL -a mackerel

関連カテゴリー

  • Apache Kafka on Heroku
暗号化鍵を使用した Apache Kafka on Heroku の暗号化 'リファレンスアーキテクチャ: Apache Kafka を使用したイベント駆動型マイクロサービス'

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