データベース

Redpandaとは?Kafka互換ブローカーの構造・ライセンス・採用判断を実装視点で解説

Kafkaのプロデューサーとコンシューマーをコードそのままで繋げられる、C++製のストリーミングブローカーがRedpandaです。ZooKeeperもJVMも要らず、Schema RegistryとHTTP Proxyまでブローカー本体に内蔵した単一バイナリで動きます。この記事では、内部構造とKafka APIの互換範囲、BSLのCommunity版と有償機能の境界、マネージドKafkaとの費用構造の差、本番移行の手順までを実装者の目線で整理しました。採用してよい条件と見送るべき条件も具体的に示します。

まとめ|Redpandaを採用する条件と、Kafkaのまま据え置く判断の分かれ目

Redpandaを入れる価値が出るのは、Kafka APIを保ったままブローカー台数とテール遅延の両方を削りたい場面に限られます。C++とthread-per-coreの設計を根拠に、公式はp99レイテンシで最大10分の1、インフラのコスト効率で3〜6倍という数値を公表しています(2026年8月時点の公表値)。一方、Amazon MSKやConfluent CloudでSLAごと運用を外部に預けられている構成へ、自前運用のブローカーを戻す動機はありません。

判断を分ける材料は3つ。ひとつ目はレイテンシ要件で、ミリ秒単位のp99をサービス品質として約束している処理があるかどうか。ふたつ目はライセンスで、Tiered StorageやIceberg Topics、RBACや監査ログはEnterprise版の機能に区分され、Community版のBSLだけでは本番構成が組み切れない場合が多くあります。3つ目は運用体制で、ブローカーの障害対応を自社で抱えられないなら、Redpanda Cloud(ServerlessまたはBYOC)かマネージドKafkaへ倒すのが妥当です。

Redpandaの定義と内部構造|単一バイナリとRaftで完結するブローカー設計

Redpandaは2019年創業のRedpanda Dataが開発する分散ストリーミングプラットフォームです。Kafkaのプロトコルを実装しているため既存クライアントからは「Kafkaクラスタ」に見えますが、内部はJava実装のKafkaとは別物です。

C++実装とthread-per-coreモデルが効くp99レイテンシの理屈

RedpandaはC++で実装され、CPUコアごとに処理を固定するthread-per-coreモデルの非同期フレームワーク上で動きます。スレッド間でロックを奪い合わないため、コア数を増やしたときのスケール特性が線形に近づきます。JVMのガベージコレクションによる停止も発生しません。

公式ドキュメントは「他のプラットフォーム比で最大10分の1のp99レイテンシ」と記載しています(2026年8月時点の公表値)。自社ワークロードでの再現性は別問題なので、実データのメッセージサイズとパーティション数を揃えたうえで、平均ではなくp99とp999を計測してください。テール遅延が要件に入っていない処理では、この差は投資回収の根拠になりません。

ZooKeeperもJVMも持たない単一バイナリ構成と運用部品数の差

Kafkaは長らくZooKeeperへの外部依存を抱え、KRaftへの移行後も、Schema RegistryやHTTP Proxyは別プロセスとして立てる構成が一般的です。Redpandaはこれらをすべて単一バイナリに同梱します。デプロイの選択肢はLinuxパッケージ、Docker、Kubernetesの3通り。

運用側で効くのは、監視対象とバージョン整合を取る相手が減ること。ZooKeeperアンサンブルの奇数台構成、JVMのヒープとGCパラメータ調整、Schema Registryの別クラスタ運用が構成から消えます。公式が引用する事例では、Teadsがブローカー台数を87%削減したと公表されています。台数削減はインスタンス費に直接効くため、ライセンス費と分けて試算してください。

Raftによる複製と書き込み耐久性の既定値、データ消失リスクの見方

Redpandaはプラットフォーム全体でRaftコンセンサスを使い、ログの書き込みと複数サーバーへの複製を調整します。別のメタデータ管理層を挟まず、データパスとメタデータの両方を同じ合意アルゴリズムで扱う設計です。

耐久性で論点になるのは、ディスクへの同期書き込みをどこまで待つかという既定値の違い。Kafkaはページキャッシュに書いた時点で応答し、レプリカ数で耐久性を担保する構成が広く使われてきました。電源断やノード同時障害の想定シナリオを決めてから設定を選んでください。決済のように1件の欠落が許されない系では、レプリカ数とacks設定を実測込みで決め、障害注入テストまで通してから本番へ載せます。

Kafka APIとの互換範囲|既存クライアントとエコシステムの移行可否

移行判断の中心は「手元のコードとツールがそのまま動くか」に尽きます。互換の範囲は公式ドキュメントに明示されており、そこを読まずに全面移行を決めるのは危険です。

Kafka 4.x系クライアントの検証状況と、そのまま動く範囲の線引き

v26.2系のリリースノートには、Kafka 4.x互換としてGoやPythonなど複数言語のクライアントを新たに検証した旨が記載されています(2026年8月時点の記載)。プロデューサー、コンシューマー、コンシューマーグループ、トランザクションといった主要APIは互換対象です。

一方、Kafka固有の管理系APIや、ブローカー内部の指標に依存する運用ツールは同じように動かない場合があります。クライアントライブラリのバージョンを一覧化し、公式の互換情報と突き合わせる作業から始めてください。ここを飛ばすと、本番投入後に管理ツール側で問題が出ます。

Schema RegistryとHTTP Proxyの内蔵で減る運用コンポーネント数

RedpandaはSchema RegistryとHTTP Proxy(Kafka REST相当)をブローカーに内蔵しています。Confluent Schema Registryを別途運用している環境からは、スキーマの持ち込み方が論点になります。

v26.2で追加されたShadowing機能は、Confluent Schema Registryからスキーマを複製し、ソースクラスタから継続的にレプリケーションできると公式が説明しています。ただしShadowingはEnterprise機能に区分されるため、Community版のみの構成では使えません。スキーマ移行をこの機能に頼る前提で計画するなら、ライセンス費を同じ稟議に載せてください。

Kafka Connectや既存ツールの接続で詰まりやすい設定の勘所

コネクタ経由でデータを出し入れしている環境では、Kafka Connectのワーカーの向け先だけを変える形で接続できます。詰まりやすいのは、ブートストラップサーバーの指定よりも認証方式とトピックの自動作成ポリシー。SASLの機構名、TLSの証明書チェーン、トピック自動作成の可否は、移行前後で明示的に揃えます。

コネクタの設計そのものを見直すなら、Kafka Connectの構成要素とコネクタ運用の整理を先に読むと、どの設定がブローカー側の都合でどれがコネクタ側の都合かを切り分けられます。コネクタ資産が多いほど、この切り分けが移行工数の大半を占めます。

提供形態とライセンス体系|BSLのCommunity版と有償機能の線引き

最も見落とされやすいのがライセンスの構造です。「オープンソースのKafka代替」という言い方は正確ではありません。

BSLの4年でApache 2.0へ切り替わるソースアベイラブルの条件

Community EditionはBusiness Source License(BSL)で提供され、GitHubでソースが公開されています。ライセンス上、Redpandaを商用のストリーミングサービスやキューイングサービスとして第三者へ提供することは認められていません。加えて、各コードのマージから4年が経過するとそのコードはApache 2.0へ切り替わる、という時限式の条項が入ります。

自社システムの内部でメッセージ基盤として動かす一般的な使い方は、この制限に抵触しません。引っかかるのは、SaaSの機能としてKafka互換エンドポイントを顧客へ提供する形態です。事業モデルが後者に寄る可能性があるなら、法務確認を先に通してください。

Enterprise版が要るTiered StorageとIcebergの機能境界

Enterprise EditionはRedpanda Community License(RCL)で提供され、新規クラスタには30日間の試用ライセンスが自動で付きます。試用が切れた後は対象機能の新規作成や変更が制限され、既存リソースの動作自体は継続する挙動です。

Enterprise側に区分される主な機能は次のとおり。設計段階でどれを前提に置いたかが、そのままライセンス費の要否になります。

  • ストレージ系:Tiered Storage、Cloud Topics、Remote Read Replicas、Topic Recovery
  • データ連携系:Iceberg Topics、Shadowing、Whole Cluster Restore
  • セキュリティ系:RBAC、Kerberos、OIDC認証、監査ログ、Schema Registryの認可
  • 性能調整系:Continuous Data Balancing、Leader Pinning、ブローカー内パーティション均衡

長期保持のTiered Storageと分析連携のIceberg Topicsを前提に構成を描いた時点で、実質的にEnterprise版の検討が確定します。

Serverless・BYOC・Dedicatedの使い分けとスループット上限

マネージド提供のRedpanda Cloudには複数の形態があり、公式の料金ページはスループットの目安を形態ごとに示しています。

提供形態 ライセンス/課金 運用の持ち主 スループット目安
Community版(自社運用) BSL(4年後にApache 2.0) 自社 ハードウェア次第
Enterprise版(自社運用) Community License(RCL) 自社 ハードウェア次第
Cloud Serverless 従量または年間コミット Redpanda 最大100 MB毎秒
Cloud BYOC 年間コミット 自社クラウド内で共同 最大2 GB毎秒

BYOCはAWS、GCP、Azureで提供され、データを自社のクラウドアカウント内に置いたまま制御面をベンダーへ預ける形態。データ所在地の要件が厳しい業種では、この形が現実解になります。Serverlessは上限が100 MB毎秒のため、ピークで数百MB毎秒を流す基盤の受け皿にはなりません(2026年8月時点の公表値)。

マネージドKafkaとの比較|MSK・Event Hubsとの選択軸と費用構造

実務で競合するのはApache Kafka本体ではなく、クラウド各社のマネージドサービスです。比較軸は「運用を誰が持つか」と「費用がどこで効くか」の2つに絞ります。

運用主体で分けるセルフホスト・BYOC・フルマネージドの比較表

同じ「Kafka互換」でも、障害時に手を動かす主体が変わります。

選択肢 障害対応の主体 費用の効き方 向く場面
Redpanda 自社運用 自社 台数削減が費用に直結 低遅延と台数削減の両立
Redpanda BYOC ベンダーと分担 年間コミット+自社インフラ データ所在地の制約が強い
Amazon MSK AWS ブローカー時間とストレージ AWS内で完結する構成
Azure Event Hubs Azure スループット単位の課金 Azure中心の取り込み基盤

AWS前提の環境なら、まずAmazon MSKの料金構造とKafka自前運用との違いを見て、そこで足りない要件だけをRedpandaの検討対象に落とす順序が正しい進め方です。Azure側で取り込み口を探しているなら、Kafka互換エンドポイントを持つAzure Event Hubsの仕組みが近い比較対象になります。

ブローカー台数の削減がクラウド費用に効く仕組みと試算時の前提

コスト効率の主張は、同じスループットをより少ないブローカーで捌けることに由来します。3〜6倍という公表値が効くのはインスタンス費とブロックストレージ費であり、開発工数や移行費用は含まれません。

試算では、現行Kafkaのブローカー台数、インスタンスタイプ、月額、ピークのスループットとp99を先に固定します。そのうえで削減後の台数を仮置きし、Enterprise版のライセンス費を足し戻して比較してください。3台が2台になる程度の規模では、ライセンス費が削減分を上回るのが普通。二桁台のブローカーを抱える環境で、初めて数字が逆転します。

Redpandaを見送るべき場面|既存Kafka資産と体制から見た採用条件

Redpandaは万能の置き換え先ではありません。条件を満たさない環境では、移行そのものが負債になります。

マネージドKafkaで足りている構成に持ち込むべきでない理由

Amazon MSKやEvent Hubsで現在の要件を満たしていて、遅延の不満が出ていないなら、Redpandaへ移す判断は見送るべきです。理由は費用ではなく責任範囲。マネージドからセルフホストへ戻すと、ブローカーのパッチ適用、ディスク枯渇の監視、リーダー偏りの是正が自社の当番表に載ります。月数万円の削減と引き換えに深夜の当番を増やす取引になっていないか、先に確認を。

失敗パターンとして多いのは、PoCで低遅延の数値だけを見て決め、本番で監視・バックアップ・バージョン更新の設計を後追いにする進め方です。PoCの評価項目には、ノード1台を落としたときの復旧手順と所要時間を必ず入れます。

Enterprise機能に依存した設計で起きるライセンス費の想定漏れ

もうひとつの見送り条件は、Tiered StorageやIceberg Topics、RBACを前提に構成を描きながら、Community版の無償枠で試算を通してしまっているケースです。30日の試用ライセンスは検証には十分でも、本番の期限にはなりません。試用が切れると対象機能の新規作成と変更が止まり、長期保持や分析連携の設計が宙に浮きます。

設計レビューでは、機能ごとにCommunity版かEnterprise版かを表に落として承認を取ってください。曖昧なまま構築へ進むと、稼働直前に稟議のやり直しが発生します。

採用してよい条件、レイテンシ要件とノード削減が両立する場面の例

逆に採用してよいのは、次の条件が重なる場面です。p99レイテンシを数ミリ秒台で要求される処理があり、現行Kafkaでブローカーを二桁台運用していて、かつインフラ運用のチームが常時稼働している。この3つが揃うなら、ブローカー削減とテール遅延の改善が同時に取れるため、移行工数を回収できる見込みが立ちます。

マルチテナントの分離やジオレプリケーションが主目的なら、Kafka互換路線より設計思想の違う選択肢を先に見た方が近道。その場合はApache PulsarとKafkaの構造差と採用判断を突き合わせ、ストレージ層の分離が要件に効くかどうかで判断してください。

検証から本番移行までの手順|データ移行と切り戻し設計の実務指針

移行は「動くかを見る検証」と「戻せるかを見る検証」の2段階に分けます。後者を省いた移行計画は承認しない方が安全です。

Dockerとパッケージで始める検証環境の作り方と確認する項目

単一ノードの検証はDockerイメージが手早く、複数ノードでの挙動確認まで行うならKubernetesかLinuxパッケージを選びます。クラスタの状態確認とトピック操作は、同梱のCLIであるrpkで完結。確認する項目は次の順に固定してください。

  1. 既存クライアントのライブラリを差し替えずに接続できるか
  2. 認証方式(SASLの機構名・TLS証明書)が現行と同じ設定で通るか
  3. 本番相当のメッセージサイズとパーティション数でp99とp999を計測
  4. ノード1台停止時のリーダー切り替え時間と、クライアント側のリトライ挙動
  5. Enterprise機能を使う場合、試用ライセンス失効時の挙動

1と2で止まるなら、性能計測へ進む価値はありません。互換性の壁を潰してから数値の話に移ります。

MirrorMaker 2でのトピック移行と切り戻し経路の残し方

既存Kafkaからのデータ移行は、Kafka側のツールであるMirrorMaker 2でトピックとコンシューマーグループのオフセットを複製する方法が現実的です。順序としては、まず新規トピックの書き込み先だけをRedpandaへ向け、既存トピックはミラーで並走させます。

切り戻し経路は、双方向のミラーを一定期間残して確保します。片方向だけにすると、切り替え後にRedpanda側へ書かれたデータが旧Kafkaに存在せず、戻す判断ができません。並走期間はコンシューマーの再処理耐性次第。冪等性が確保できていない処理があるなら2週間程度は見ておくべきです。

監視とスキーマ管理まで含めた本番運用の設計と、体制づくりの要点

本番移行の前に決めるのは、メトリクスの取得先、ディスク使用率のしきい値、パーティションのリーダー偏りを検知する条件、スキーマ変更の承認フローの4点です。ブローカーが減っても監視対象は消えません。

ストリーミング基盤は単体で完結せず、後段の分析基盤やMLOpsのパイプラインと一体で設計しないと、トピック設計がそのまま分析側の負債になります。取り込みから保持、分析まで通しで組む段階で外部の手を借りるなら、データ分析基盤構築・MLOps構築支援のように基盤設計と運用移管まで相談できる先を選ぶのが安全。ブローカーだけを入れ替えて終わりにする計画は、半年後にデータ品質の問題として跳ね返ります。

よくある質問

実装者から出やすい質問を、判断に使える粒度でまとめました。

RedpandaはKafkaのコードをそのまま置き換えられますか?

プロデューサー、コンシューマー、トランザクションといった主要なKafka APIは互換対象で、v26.2系ではKafka 4.x互換としてGoやPythonのクライアント検証が進んでいます(2026年8月時点の公式記載)。接続先を変えるだけで動くケースは多いものの、ブローカー内部の指標に依存する管理ツールや一部の管理系APIは同じように動きません。移行前にクライアントライブラリの一覧を作り、公式の互換情報と突き合わせてください。

Community版だけで本番運用はできますか?

要件次第です。単純なメッセージ中継であればCommunity版のBSLで運用できます。ただしTiered Storage、Cloud Topics、Iceberg Topics、RBAC、監査ログはEnterprise版の機能に区分されます。長期保持や権限管理を前提にした構成では、Community版だけで本番要件を満たせません。新規クラスタに付く30日の試用ライセンスは検証用と割り切るのが安全です。

RedpandaとApache Pulsarはどちらを選ぶべきですか?

選定軸が違います。Redpandaは既存のKafka資産をそのまま使い、運用部品とブローカー台数を減らす方向の選択肢。Pulsarはブローカーとストレージ層を分離した構造で、マルチテナント分離やジオレプリケーションが要件の中心にある場合に効きます。既存がKafkaで移行コストを抑えたいなら前者から検討してください。

Kafkaからの移行にはどれくらいの停止時間が必要ですか?

設計次第で、無停止に近い形も取れます。一般的な進め方は、MirrorMaker 2で既存トピックを並走ミラーしつつ、新規の書き込み先から順にRedpandaへ切り替える方式。この場合の停止はコンシューマーの切り替え時だけ。逆に一括切り替えを選ぶとオフセットの整合確認に時間がかかり、数時間規模の停止が必要になることもあります。切り戻し用に双方向ミラーを残すかどうかで、計画できる停止時間の幅は変わってきます。

Redpandaのバージョンはどのくらいの頻度で上がりますか?

年号と連番を組み合わせた版番号体系が採られており、2026年8月時点の公式ドキュメントが示す現行版はv26.2.1系、そのEOLは2027年7月28日と記載されています。1年強でサポート期限を迎える計算になるため、年1回以上の更新を運用計画へ最初から織り込む前提で考えます。v26.2ではアップグレードの確定を保留してロールバック経路を残す機能が入り、更新時の切り戻しは以前より組み立てやすくなりました。

関連記事

資料請求

RELATED POSTS 関連記事