すべてのプロダクト
Search

このプロダクト

    ApsaraMQ for Kafka:用語

    ドキュメントセンター

    ApsaraMQ for Kafka:用語

    最終更新日:Mar 19, 2025

    このトピックでは、ApsaraMQ for Kafka で使用される用語について説明し、ApsaraMQ for Kafka をより深く理解し、使用できるようにします。

    Apache Kafka

    データストリーム処理用の分散型オープンソースプラットフォーム。 このプラットフォームを使用すると、データストリームをリアルタイムで公開、購読、保存、および処理できます。 詳細については、「Apache Kafka」をご参照ください。

    ApsaraMQ for Kafka

    Alibaba Cloud が提供するフルマネージド Apache Kafka サービス。 このサービスにより、デプロイと O&M から解放され、高いスケーラビリティ、信頼性、スループットを備えた費用対効果の高いサービスが提供されます。 詳細については、「ApsaraMQ for Kafka とは」をご参照ください。

    ZooKeeper

    アプリケーション用の分散型オープンソース調整サービス。 ApsaraMQ for Kafka では、ZooKeeper はクラスターと構成の管理、およびリーダーの選出に使用されます。 ZooKeeper は ApsaraMQ for Kafka アーキテクチャの一部です。 ZooKeeper について心配する必要はありません。

    broker

    ApsaraMQ for Kafka のサーバーノード。 ApsaraMQ for Kafka は、インスタンスのトラフィック仕様に基づいて broker の数量と構成を自動的に変更するフルマネージドサービスを提供します。 broker の詳細について心配する必要はありません。

    cluster

    複数の broker の集合。

    instance

    ApsaraMQ for Kafka のクラスターに対応する独立したリソースエンティティ。

    VPC 接続インスタンス

    仮想プライベートクラウド ( VPC ) エンドポイントのみを提供し、インスタンスがデプロイされている VPC からのみアクセスできるインスタンス。

    インターネットおよび VPC 接続インスタンス

    パブリックエンドポイントと VPC エンドポイントを提供し、インスタンスがデプロイされている VPC から、およびインターネット経由でアクセスできるインスタンス。

    メジャーバージョンアップグレード

    メジャーバージョンが変更されるアップグレード。 たとえば、ApsaraMQ for Kafka インスタンスをバージョン 0.10.x からバージョン 2.x にアップグレードできます。 詳細については、「インスタンスバージョンのアップグレード」をご参照ください。

    マイナーバージョンアップデート

    メジャーバージョンが変更されないアップデート。 たとえば、ApsaraMQ for Kafka インスタンスをバージョン 0.10 からバージョン 0.10.2 に、またはバージョン 0.10.2 から 0.10.2 カーネル最適化バージョンにアップデートできます。 詳細については、「インスタンスバージョンのアップグレード」をご参照ください。

    endpoint

    プロデューサーまたはコンシューマーが ApsaraMQ for Kafka に接続するために使用するアドレス。 このアドレスは、Broker IP address:Port number の形式の broker の IP アドレスとポート番号で構成できます。 また、このアドレスは、ApsaraMQ for KafkaInstance domain name:Port number の形式の エンドポイントの比較 インスタンスのドメイン名とポート番号で構成することもできます。 詳細については、「」をご参照ください。

    message

    ApsaraMQ for Kafka で情報を転送するためのキャリア。 メッセージには、ページビュー、サーバーログ、CPU やメモリリソースなどのシステムリソースに関する情報を含めることができます。 ApsaraMQ for Kafka では、メッセージはバイト配列です。

    メッセージ保持期間

    ディスク容量が十分な場合にメッセージを保持できる最大期間。

    • ディスク使用率が 85% に達すると、ディスク容量が不足していると見なされ、サービスの可用性を確保するために、システムはメッセージが保存された順序でメッセージを削除します。

    • 有効な値: 24 ～ 480。 デフォルト値: 72。 単位: 時間。

    最大メッセージサイズ

    ApsaraMQ for Kafka で送受信できるメッセージの最大サイズ。

    • Standard Edition および Professional Edition のインスタンスでは、最大 10 MB のメッセージサイズを指定できます。

    • 最大メッセージサイズを新しい値に変更する前に、新しい値がインスタンスのメッセージプロデューサーとメッセージコンシューマーに指定した最大メッセージサイズと同じであることを確認してください。

    パブリッシュ/ サブスクライブモデル

    サービス間の非同期通信モデル。 パブリッシャーは、メッセージを購読するサブスクライバーに関する情報を取得する必要なく、特定のトピックにメッセージを送信します。 サブスクライバーは、メッセージを送信するパブリッシャーに関する情報を取得する必要なく、特定のトピックからメッセージを受信します。 ApsaraMQ for Kafka は、パブリッシュ/ サブスクライブモデルをサポートしています。 詳細については、「ApsaraMQ Kafka のパブリッシュ/ サブスクライブモデル」をご参照ください。

    subscription

    コンシューマーグループとトピック間の購読関係。 ApsaraMQ for Kafka では、特定のトピックを購読している接続済みコンシューマーグループのステータスをクエリできます。 切断されたコンシューマーグループのステータスはクエリできません。

    producer

    ApsaraMQ for Kafka にメッセージを送信するアプリケーション。

    consumer

    ApsaraMQ for Kafka からメッセージを受信するアプリケーション。

    group

    同じグループ ID を持つコンシューマーのグループ。 トピック内のメッセージが同じコンシューマー group 内の複数のコンシューマーによって消費される場合、トピック内の各メッセージはコンシューマーの 1 つにのみ配信されます。 これにより、コンシューマー間の負荷が分散され、トピック内のメッセージを同時に消費できます。

    topic

    メッセージを分類するために使用されるメッセー ジトピック。

    トピックトラフィックリバランス

    ApsaraMQ for Kafka クラスターがスケールアウトされた後に、トピックトラフィックを均等に再配布する操作。 詳細については、「トピックトラフィックのリバランス」をご参照ください。

    partition

    ApsaraMQ for Kafka では、各トピックはパーティションに分割されます。 各パーティションは、独立したデータの読み取りと書き込みを可能にする順序付けられたメッセージキューです。 トピック内のパーティションの数は、ApsaraMQ for Kafka クラスターのスループットと同時実行性によって決まります。

    replicas

    ApsaraMQ for Kafka では、各パーティションに複数のレプリカを作成して、データの冗長性と高可用性を実現できます。 レプリカの数は、パーティションのレプリカの数です。 ほとんどの場合、パーティションのレプリカの数は、ApsaraMQ for Kafka クラスターの可用性とフォールトトレランス機能によって決まります。 可用性とデータの冗長性が向上しますが、レプリカの数が多いと、ストレージとネットワークのオーバーヘッドが増加します。 デフォルトでは、各パーティションには 3 つのレプリカがあります。つまり、パーティションレプリケーション係数は 3 です。

    パーティションレプリカ

    パーティションレプリカの数は、トピック内のすべてのパーティションのレプリカの総数です。 パーティションレプリカの数は、次の式を使用して計算されます。パーティションレプリカの数 = トピック内のパーティションの数 × パーティションレプリケーション係数。 たとえば、トピックに 10 個のパーティションがあり、各パーティションに 3 つのレプリカがある場合、トピック内のパーティションレプリカの数は 30 です。 パーティションレプリカの数は、ApsaraMQ for Kafka クラスターのストレージとスループットに影響します。 フォールトトレランスと読み取りパフォーマンスは向上しますが、パーティションレプリカの数が多いと、ネットワークとストレージのオーバーヘッドが増加します。

    offset

    メッセージがパーティションに到着したときにメッセージに割り当てられるシーケンス番号。

    earliest offset

    パーティション内の最初のメッセージのオフセット。 パーティションの最も古いオフセットをクエリする方法については、「パーティションステータスの表示」をご参照ください。

    maximum offset

    パーティション内の最新のメッセージのオフセット。 パーティションの最新のオフセットをクエリする方法については、「パーティションステータスの表示」をご参照ください。

    consumer offset

    パーティションで消費されるメッセージの最新のオフセット。 コンシューマーオフセットをクエリする方法については、「コンシューマー情報の表示」をご参照ください。

    latest consumption time

    グループによって消費された最新のメッセージが ApsaraMQ for Kafka broker に公開および保存された時刻。 メッセージが蓄積されていない場合、時刻はメッセージ送信時刻に近くなります。

    accumulated messages

    パーティションに蓄積されたメッセージの総数。 値は、最新のオフセットからコンシューマーオフセットを引いた値です。 蓄積されたメッセージの数は、ApsaraMQ for Kafka の重要な指標です。 大量のメッセージが蓄積されると、コンシューマーがブロックされたり、消費率が生産率に追いつかなくなる可能性があります。 この場合、コンシューマーのステータスを分析し、消費率を向上させる必要があります。 蓄積されたすべてのメッセージをクリアし、最新のオフセットからメッセージの消費を開始するか、時点に基づいてコンシューマーオフセットをリセットできます。 詳細については、「コンシューマーオフセットのリセット」をご参照ください。

    ローカルストレージ

    ネイティブ Apache Kafka の In-Sync Replicas ( ISR ) アルゴリズムを使用するストレージエンジン。 compaction、冪等性、トランザクション、パーティション順序付けメッセージなどの特別な要件がある場合は、ローカルストレージを使用することをお勧めします。 詳細については、「ストレージエンジン間の比較」をご参照ください。

    クラウドストレージ

    Alibaba Cloud ディスクのアルゴリズムを使用するストレージエンジン。 クラウドストレージには、Alibaba Cloud の基盤となるストレージの利点があります。 ローカルストレージと比較して、クラウドストレージは、自動スケーリング、信頼性、可用性、費用対効果の面で優れたパフォーマンスを提供します。 ほとんどの場合、クラウドストレージを使用することをお勧めします。 詳細については、「ストレージエンジン間の比較」をご参照ください。

    cleanup policy

    ログクリーンアップポリシー。 ローカルストレージを使用する場合にのみ、ログクリーンアップポリシーを構成する必要があります。 ApsaraMQ for Kafka Professional Edition インスタンスでトピックを作成する場合にのみ、ローカルストレージをストレージエンジンとして指定できます。 ApsaraMQ for Kafka は、次のログクリーンアップポリシーをサポートしています。

    • Delete: デフォルトのログクリーンアップポリシー。 システムに十分なストレージ容量がある場合、メッセージは最大保持期間に基づいて保持されます。 ストレージ使用率が 85% を超えると、システムはサービスの可用性を確保するために、最も古い保存メッセージを削除します。

    • Compact: Apache Kafkaで使用されるログ圧縮ポリシー。ログ圧縮により、同じキーを持つメッセージの最新の値が保持されます。このポリシーは、障害が発生したシステムの復元や、システムの再起動後のキャッシュの再読み込みなどのシナリオに適しています。たとえば、Kafka ConnectまたはConfluent Schema Registryを使用する場合、システムの状態と構成に関する情報をログ圧縮トピックに保存する必要があります。

      重要

      ログ圧縮トピックは、Kafka Connect や Confluent Schema Registry などの特定のクラウドネイティブコンポーネントでのみ使用できます。詳細については、「aliware-kafka-demos」をご参照ください。

    normal message

    デフォルトでは、同じキーのメッセージは、送信された順序で同じパーティションに保存されます。 クラスターで broker の再起動または障害が発生した場合、クラスター内のごく少数のメッセージの順序が正しくない可能性があります。 詳細については、「ストレージエンジン間の比較」をご参照ください。

    partitionally ordered message

    デフォルトでは、同じキーのメッセージは、送信された順序で同じパーティションに保存されます。 クラスターで broker 障害が発生した場合でも、クラスター内のメッセージの順序は変わりません。 ただし、障害が発生した broker が復元されるまで、特定のパーティションのメッセージを送信できません。 詳細については、「ストレージエンジン間の比較」をご参照ください。

    connector

    ApsaraMQ for Kafka と他の Alibaba Cloud サービス間でデータを同期する ApsaraMQ for Kafka コンポーネント。 詳細については、「概要」をご参照ください。

    tag

    ApsaraMQ for Kafka では、タグはリソースを識別するために使用されます。 タグを使用して、リソース機能に基づいて ApsaraMQ for Kafka リソースを分類し、リソースの検索と集計を容易にすることができます。 詳細については、「タグの管理」をご参照ください。

    RAM

    ユーザー ID とリソースアクセス許可を管理するために Alibaba Cloud が提供するサービス。 Resource Access Management ( RAM ) は、ApsaraMQ for Kafka コンソールで、または API オペレーションを呼び出すことによってメッセージを送受信するユーザーのアクセス制御を実装する場合にのみ適用されます。 詳細については、「概要」をご参照ください。

    ACL

    Simple Authentication and Security Layer ( SASL ) ユーザーとクライアントが SDK を使用してメッセージを送受信するための許可を管理するために ApsaraMQ for Kafka が提供するサービス。 この機能は、オープンソース Apache Kafka の機能と一致しています。 アクセス制御リスト ( ACL ) 機能は、SDK を使用してメッセージを送受信するユーザーのアクセス制御を実装する場合にのみ適用されます。 詳細については、「概要」をご参照ください。