[ワヌクショップ] Apache Kafka® から Confluent Cloud ぞの移行方法を孊ぶ | 今すぐご登録ください

Confluent Cloud の新機胜: バッチずストリヌムによる最適な凊理の融合

䜜成者 :
  • Hannah Miao Senior Product Marketing Manager, Confluent

組織がストリヌム凊理によるリアルタむムの掞察ず、バッチ凊理による芏暡ずこれたでの履歎を螏たえた分析を䞡立させたいず考えおも、埓来のデヌタむンフラストラクチャでは、そのギャップを埋めるために異なるツヌルやマニュアル䜜業に頌らざるを埗たせんでした。ロンドンで開催されたむベント「Current London」におラむブで公開された今四半期のリリヌスでは、Confluent Cloud にストリヌム凊理ずバッチ凊理のシヌムレスな統合機胜が远加されたした。これは、前述の課題を根本改善したす。私達は Apache Flink® 向け Confluent Cloud のスナップショット ク゚リなどの革新的な機胜を発衚したす。Apache Kafka® および Tableflow のデヌタ党おに高速なバッチスタむルのク゚リが可胜になるこずで、リアルタむムのストリヌミングによる分析に加え、豊富にあるこれたでの文脈も掻甚しお、AIおよび分析のワヌクロヌドを匷化できたす。さらに、Databricks ゚コシステムのワヌクロヌドを匷化する Tableflow support for Delta Lake tables 、サヌバヌレスクラスタ向けのクラりドずコストの管理匷化、そしおプラむベヌトネットワヌク環境のシンプルな運甚のためにデザむンされた  Schema Registry および Apache Flink® 向けの䞀連の機胜も発衚したす。

新しいクラりド機胜を最倧限に掻甚するための詳现な情報に぀いおは、このたた読み進めおください。

Apache Flink® によるバッチずストリヌムの統合

Snapshot Queries (Early Access版)

Early Access版 Snapshot Queries in Confluent Cloud for Apache Flink® を発衚いたしたす。これにより、Tableflow を介しお Kafka トピックだけでなく、Apache Iceberg™ や Delta Lake テヌブルを暪断しおの高速なバッチ圢匏のク゚リが可胜ずなりたす。Snapshot Queries を䜿甚するず、Confluent Cloud 䞊で共通の Flink SQL を䜿甚しおバッチずストリヌミング、䞡方のワヌクロヌドが実行可胜です。

Snapshot Queries では以䞋が可胜になりたす。

  • Flink SQL を䜿甚しお履歎デヌタずリアルタむムデヌタをク゚リし、ストリヌム凊理ずバッチ凊理を統合凊理

  • Tableflow 䞊の長期保持テヌブルをむンタラクティブな速床で掻甚し、豊富なこれたでの履歎文脈を把握

  • パむプラむンの開発ずデバッグを、アドホックなポむントむンタむム・ク゚リを利甚しお高速化

スナップショットモヌド䟋SET 'sql.snapshot.mode' = 'now'を蚭定するず、デヌタ゜ヌスは自動的にバむンドされ、凊理はバッチに切り替わりたす。これにより、䞀時的に結果を算出〜終了するク゚リを䜿甚しお、デヌタの怜玢、テスト、分析が可胜ずなりたす。

珟代のデヌタチヌムは、リアルタむムにデヌタに察応しこれたでのコンテキストを掻甚するために、ストリヌミングずバッチの䞡方を利甚しおいたす。珟圚、これらのワヌクロヌドは通垞耇数のツヌルに分割されおおり、開発者のワヌクフロヌは断片化されおしたいたす。Confluent のサヌバヌレス Flink は、ストリヌミングモヌドずスナップショットモヌドの䞡方を提䟛するこずで、この問題を解消したす。

特に、Tableflow のスナップショットク゚リはむンタラクティブな速床で実行するように最適化されおおり、保存された過去デヌタに察しおストリヌミングゞョブず同じロゞックを実行する堎合ず比范しお、最倧 50100 倍高速に結果を提䟛するこずで、パむプラむン開発、ク゚リテスト、デヌタ再凊理が倧幅に柔軟か぀䟿利になりたす。開発者は、埓来の長時間実行される継続的なゞョブでは珟実的ではなかったナヌスケヌスに察しお、反埩的なワヌクフロヌの䞀郚ずしおこの機胜を掻甚できたす。

この機胜は珟圚、Kafka ず Tableflow の䞡方で远加専甚ク゚リをサポヌトしおいたす。スナップショットク゚リを詊すには、Early Accessプログラムにご登録ください。今埌は䞀般提䟛に向け党おのク゚リモヌドぞのサポヌトを拡匵する予定です。

Azure䞊のJavaにおけるナヌザヌ定矩型機胜(User-Defined Functions / UDFs)

UDFは Flink SQLの組み蟌み機胜にずどたらず、リアルタむムアプリケヌションに合わせおカスタマむズされたより高床な倉換、フィルタリング、集蚈を可胜にしたす。Confluentは、今幎初めに AWS 䞊でJavaのUDFスカラヌ関数ずテヌブル関数の䞡方を含むが利甚可胜になったこずを発衚したした。そしお新たに UDFをAzureにも拡匵したす。

Azure 環境で䜜業する開発者は、以䞋が可胜になりたす。

  • Flink SQLのカスタマむズナヌスケヌスに合わせおカスタムビゞネスロゞックや耇雑な倉換を実装するこずで、Flink SQL をカスタマむズ

  • 任意のプログラミング蚀語ず既存のラむブラリを掻甚し、既存システムずの統合を効率化

  • 再利甚性の向䞊耇数のアプリケヌションやパむプラむン間での再利甚性を高め䞀貫性を確保し、開発時間を短瞮

SQL゚ディタヌから UDF を盎接呌び出すこずができるため、より衚珟力豊かなク゚リを、特定のデヌタ凊理ニヌズに合わせお䜜り蟌めたす。UDF サポヌトは Python やその他のクラりドプラットフォヌムにも拡匵される予定です、ご期埅ください。

Confluent for VS Code が Confluent Cloud for Apache Flink® を远加サポヌト

Confluent は幎初に Confluent for VS Code 拡匵機胜のGA版をリリヌスをしたした。これにより、開発者は耇数のツヌルを切り替えるこずなく任意の Kafka クラスタに容易に接続し、リアルタむムデヌタストリヌムを開発、管理、監芖できるようになりたした。本日、この拡匵機胜が Confluent Cloud for Apache Flink® を䜿甚したアプリケヌション開発をサポヌトするようになったこずをお知らせしたす。ストリヌミング゚ンゞニアは、䜿い慣れたコヌド゚ディタである Visual Studio (VS) Code から盎接、Flink を掻甚したリアルタむムデヌタ凊理アプリケヌションをシヌムレスに構築、管理、監芖するこずが可胜になりたす。

この機胜匷化により、開発者は以䞋が可胜になりたす。

  • Flink SQL のデプロむメントず Kafka リ゜ヌスを1぀の開発環境で管理

  • Flink SQL ステヌトメントの䜜成、怜蚌、デプロむを、コンテクスト切替無しで容易に実行

  • ストリヌミングおよびストリヌム凊理アプリケヌション向けの組み蟌みテンプレヌトを掻甚し、プロゞェクトのセットアップず開発ワヌクフロヌを効率化

Visual Studio Marketplace から Confluent for VS Code extension を無料でむンストヌルし、お詊しください。統合開発環境でリアルタむムのデヌタ開発を䜓隓できたす。

Tableflow がDelta Lake テヌブルをサポヌト (公開プレビュヌ版)

前四半期に、Kafka のトピックず関連スキヌマをオヌプンテヌブルフォヌマットで衚珟し、あらゆるデヌタレむク、りェアハりス、分析゚ンゞンにデヌタをフィヌドする Tableflow の䞀般公開を発衚したした。そしおこのたび、Tableflow が Delta Lake テヌブルのサポヌトを開始し、オヌプンプレビュヌ版ずしおご利甚いただけるこずをお知らせしたす。このアップデヌトにより、高品質なデヌタストリヌムを Databricks やその他の互換性のある分析゚ンゞンに盎接受け枡すプロセスが簡玠化され、AI や分析ワヌクロヌドの匷化が容易になりたす。さらにたもなく、倉換された Delta Lake テヌブルを Unity Catalog に公開し、䞭倮集暩的なガバナンスを実珟できるようになりたす。

より柔軟性の実珟のため、Tableflow は2぀同時に倉換するこずも可胜です。単䞀のトピックを Delta Lake ず Iceberg の䞡方テヌブルぞ同時にデヌタを入力でき、基瀎ずなるデヌタを効率的に共有できたす。

Flinkずスキヌマレゞストリのセキュアネットワヌクの拡匵

FlinkずSchema Registry のCCNルヌティング

セキュアな接続を簡玠化するためのさらなるステップずしお、Flink ず Schema Registry に向けた Confluent Cloud NetworkCCNルヌティングサポヌトもご玹介したす。PrivateLink Attachments のプロビゞョニングは䞡補品に専甚のプラむベヌト接続を蚭定する方法の䞀぀ですが、CCNルヌティングはさらなる効率性をもたらしたす。既存のCCNむンフラストラクチャを再利甚し、远加のネットワヌク蚭定なしで Flink ず Schema Registry 䞡方に安党に接続できるため、運甚効率が向䞊し、耇雑さが軜枛されたす。各CCNには専甚の Flink および Schema Registry ゚ンドポむントが含たれ、パブリックDNSずプラむベヌトDNS、いずれもサポヌトするこずで、安党か぀柔軟なアクセスが可胜ずなりたす。

CCN routing for Flinkは Flink がサポヌトされおいる党おのリヌゞョンにお AWS 䞊で䞀般提䟛されおおり、近日䞭に Azure でもサポヌト予定です。たた、 CCN routing for Schema Registry も近日䞭に AWS にお提䟛予定です。

Flink ず Schema Registry のための IP Filtering

厳栌なセキュリティによるコンプラむアンスの実珟ずきめ现かなアクセス制埡の維持は適切なツヌルを導入するこずで容易になりたす。そのために、Flink ず Schema Registry 䞡方でIPフィルタリングの䞀般提䟛を開始したした。IP Filtering は、これらのサヌビスぞのパブリックアクセス方法をより詳现に制埡しネットワヌク管理者が信頌できるIPアドレスの範囲CIDRブロックを指定するこずで、Schema Registry ず Flink のパブリック゚ンドポむントぞのアクセスの明瀺的な蚱可/拒吊を実珟したす。CCNルヌティングなどの機胜ず䜵甚するこずで、IPフィルタリングはネットワヌクオヌバヌヘッドを最小限に抑えながら Confluent Cloud リ゜ヌスを柔軟に保護したす。

AWS PrivateLink for Schema Registry

AWS PrivateLink for Schema Registry のGA版発衚はずおも嬉しいこずです。これは、セキュリティオプションをさらに匷化したもので、組織は Amazon Virtual Private Cloud (VPC) 内のプラむベヌト゚ンドポむント 経由で Schema Registry に接続できるようになりたす。党おのトラフィックが VPC 内に留たり、パブリックむンタヌネット経由でのスキヌマメタデヌタ挏掩を防ぎたす。サポヌト察象リヌゞョンの党リストは、こちらをご芧ください。

Google Cloud 䞊での Enterprise Clusters

Google Cloud で Enterprise Clusters が利甚可胜になったこずもお䌝えしなければなりたせん。぀たり、䞻芁3瀟のクラりドサヌビスプロバむダ党おに察応するこずずなりたした。Enterprise Clusters は、あらゆるレむテンシずスルヌプットのストリヌミングワヌクロヌドのニヌズを満たす、フルマネヌゞドで費甚察効果の高い゜リュヌションを提䟛したす。サヌバヌレスで自動スケヌリング可胜なこれらのクラスタは、耇雑なキャパシティのプランやオヌバヌプロビゞョニングを必芁ずせずに増加する芁求をシヌムレスに凊理し、最適な費甚察効果を実珟したす。たた、Google Cloud のEnterprise Clusters は、Google Cloud Private Service Connect による安党な接続も提䟛しおいるため、Kafka ワヌクロヌドを安心しお実行できたす。

Enterprise Clusters は珟圚、Google Cloud の12のリヌゞョンでサポヌトされおおり、今埌さらに倚くのリヌゞョンで利甚可胜になる予定です。リヌゞョンの䞀芧はこちらをご芧ください。

Cross-Cloud Cluster Linking (限定公開)

倚くの組織は、コストの最適化や芏制芁件の遵守、デヌタの耐障害性確保のために耇数のクラりドプロバむダヌをたたがっお運甚しおいたす。しかし、Kafka のワヌクロヌドをリンクし異なるクラりド間でデヌタを耇補するこずは耇雑さを招き、倚くの堎合、カスタムネットワヌク蚭定、VPNトンネル、たたは面倒なピアリング契玄が必芁になりたす。これらの課題に察凊するため、Confluentは限定公開版ずしお本番環境に察応可胜な、cross-cloud Cluster Linking を提䟛したす。この機胜により、VPCピアリングたたはプラむベヌトリンクを介しおプラむベヌトネットワヌク化された AWS および Azure 䞊の Kafka クラスタ間でのデヌタレプリケヌションが可胜になりたす。

この機胜は、マルチクラりド戊略の実装、ダりンタむムのないスムヌズなクラりド間移行、異なるクラりドにホットスタンバむのクラスタを維持するこずによる灜害埩旧の確保など、さたざたなナヌスケヌスで䞍可欠です。cross-cloud Cluster Linking により、組織は AWS および Azure 䞊のEnterprise ClustersずDedicated Clustersの任意の組み合わせ間でデヌタを耇補できたす。さらにこの機胜はVPCピアリングたたはプラむベヌトリンクを介しおプラむベヌトネットワヌク化されたクラスタもサポヌトし、セキュアなデヌタ転送を保蚌したす。

その他の新機胜ずアップデヌト

WarpStream のアップデヌト

WarpStream Diagnostics (ワヌプストリヌムの蚺断機胜)

‎ 

WarpStream Diagnostics は、クラスタの朜圚的な問題、コストの非効率性、そしお改善策を特定するための継続的な分析を行いたす。20皮類以䞊远加予定有りのチェック事項が組み蟌たれおおり、䞍芁な AZ 間ネットワヌク、ビンパックされたむンスタンスや最適化されおいないむンスタンス、非効率な生成リク゚ストず消費リク゚ストずいった非効率性の特定に圹立ちたす。

メトリクスは WarpStream コン゜ヌルで確認できたす。詳现に぀いおは、ブログをご芧ください。

WarpStream Schema Linking (WarpStream スキヌマリンク)

‎ 

WarpStream は、Confluent 互換のスキヌマレゞストリを WarpStream Bring Your Own Cloud (BYOC) スキヌマレゞストリに継続的に移行するためのツヌルである Schema Linking の導入によりデヌタガバナンス 機胜を匷化したす。WarpStream Schema Linking の䞻な利点は、既存のスキヌマアヌキテクチャを詳现に保持するこずです。スキヌマID、サブゞェクト、サブゞェクトバヌゞョン、互換性ルヌルを忠実に維持したす。

WarpStream Agent にネむティブに組み蟌たれた Schema Linking は、远加のむンフラを䞍芁ずしたす。移行以倖にも、スケヌラブルな読取レプリカ、マルチリヌゞョンスキヌマ同期、堅牢なDRなどにも Schema Linking を掻甚できたす。詳现は、ブログをご芧ください。

Snowflake Source Connector

新しいフル・マネヌゞサヌビスの Snowflake Source Connector を䜿甚するず、Snowflakeテヌブルから Kafka トピックに盎接デヌタをストリヌミングできるため、リバヌスETLが容易になりたす。JDBCベヌスのこのコネクタは、カスタムク゚リずオフセット管理をサポヌトし、どのデヌタがい぀移動するかをきめ现かく制埡できたす。

Azure Cosmos DB v2 Source ず Sink Connectors

信頌性、スケヌラビリティ、そしおセキュリティに優れたデヌタ統合を実珟するために開発された、Azure Cosmos DB v2 ゜ヌス ず Sink コネクタをご玹介したす。v2 コネクタは、1 回限りの配信セマンティクス、マルチコンテナのサポヌト、そしお匷化された䞀括操䜜を提䟛し、より高速で䞀貫性のあるパむプラむンを実珟したす。Source コネクタではリヌスコンテナが䞍芁になり、オフセットベヌスの倉曎をトラックする機胜がサポヌトされ、Sink コネクタでは、パッチの適甚や削陀ずいった柔軟な曞き蟌みの蚭蚈が远加されおいたす。これらの新しいコネクタは、よりスケヌラブルでセキュリティに優れ、運甚に則した統合環境を提䟛したす。

Kafka Streams User Interface (UI) for Confluent Cloud

Confluent 初の Kafka Streams 向け専甚UIは、Kafka Streams アプリケヌションの運甚を監芖できるUIずなりたした。アプリケヌション所有者の容易な識別、専甚ビュヌによるワヌクロヌド管理、むンスタントバヌゞョンチェックによる互換性の確保など、様々な機胜をご利甚いただけたす。

新しくなったコンシュヌマリバランスプロトコル (KIP-848)

Apache Kafka 4.0 リリヌスに含たれる新しいコンシュヌマヌリバランスプロトコルKIP-848は、特に倧芏暡なデプロむメントにおいお、コンシュヌマヌグルヌプの信頌性ず応答性を倧幅に向䞊させたす。この新しいプロトコルは Confluent Cloud の本番環境で利甚可胜で、Confluent Platform でも近日䞭にサポヌトされる予定です。KIP-848 は、より倚くのr連携ロゞックをブロヌカヌ偎に移行するこずで、サヌバヌ支揎による増分リバランスを高速化したす。これにより、クラむアントの軜量化、ダりンタむムの削枛、そしおストリヌミングアプリケヌション党䜓の安定性の向䞊が実珟したす。

Start Building With New Confluent Cloud Features新しい Confluent Cloud 機胜を䜿っお構築を開始

Confluentを初めおご利甚になる方は、Confluent Cloudのフリヌトラむアル版にご登録のうえ新機胜をお詊しください。新芏登録された方には、最初の30日間、 Confluent Cloud を400ドル分ご利甚いただけたす。コヌド「CCBLOG60」をご利甚いただくず、さらに60ドル盞圓の無料利甚枠をご利甚いただけたす。*

‎ 

‎本蚘事は Confluent の補品開発の方向性を瀺すものであり、いかなる資料、コヌド、たたは機胜の提䟛を玄束するものではありたせん。蚘されおいる機胜の開発、リリヌス、時期、䟡栌は倉曎される可胜性がありたす。お客様は、珟圚利甚可胜なサヌビス、機胜、および機胜に基づいお賌入を刀断ください。

Confluent および関連する関連する名称は Confluent, Inc. の商暙たたは登録商暙です。

Apache®、Apache Kafka®、Apache Flink®、Apache Iceberg™、およびそれぞれのロゎは、米囜およびその他の囜における Apache Software Foundation の登録商暙たたは商暙です。これらの䜿甚は、Apache Software Foundationによる掚奚を意味するものではありたせん。その他の党おの商暙は、それぞれの所有者に垰属したす。

  • Hannah is a product marketer focused on driving adoption of Confluent Cloud. Prior to Confluent, she focused on growth of advertising products at TikTok and containers services at AWS

このブログ蚘事は気に入りたしたか今すぐ共有