共用方式為


使用記錄壓縮

本文顯示如何在事件中樞中使用記錄壓縮功能。 若要了解記錄壓縮的詳細資料,請參閱記錄壓縮

在本文中,您將遵循下列重要步驟:

  • 建立壓縮的事件中樞/Kafka 主題。
  • 將事件發佈至壓縮的事件中樞。
  • 從壓縮的事件中樞取用事件。

注意

基本層不支援記錄壓縮功能。

建立壓縮的事件中樞/Kafka 主題

本節顯示如何使用 Azure 入口網站和 Azure Resource Manager (ARM) 範本來建立壓縮的事件中樞。

您可以遵循下列步驟,使用 Azure 入口網站建立壓縮的事件中樞。

  1. 瀏覽至事件中樞命名空間。
  2. 在 [事件中樞命名空間] 頁面上,選取左功能表中的 [事件中樞]。
  3. 在視窗頂端選取 [+ 事件中樞]。 Screenshot of event hub creation UI.
  4. 輸入事件中樞的名稱,並指定分割區數目。 因為我們要建立壓縮的事件中樞,請選取 [壓縮原則] 作為 [壓縮],並為 [標記保留時間] 提供所需的值。 Screenshot of the event hubs creation UI with compaction related attributes.
  5. 選取 [建立],然後建立壓縮的事件中樞。

觸發壓縮

事件中樞服務會決定何時應該執行指定壓縮事件中樞的壓縮作業。 當事件的數量相當多或指定事件記錄的總大小大幅成長時,壓縮的事件中樞便會達到壓縮閾值。

將事件發佈至壓縮的主題

將事件發佈至壓縮的事件中樞,與將事件發佈至一般事件中樞是一樣的。 身為用戶端應用程式,您只需要判斷使用分割區索引鍵所設定的壓縮索引鍵。

使用事件中樞 SDK (AMQP)

使用事件中樞 SDK,您可以設定分割區索引鍵和發佈事件,如下所示:

var enqueueOptions = new EnqueueEventOptions
{
    PartitionKey = "Key-1"
    
};
await producer.EnqueueEventAsync(eventData, enqueueOptions);

使用 Kafka

若使用 Kafka,即可在建立 ProducerRecord 時設定分割區索引鍵,如下所示:

ProducerRecord<String, String> record = new ProducerRecord<String, String>(TOPIC, "Key-1" , "Value-1");

配額和限制

限制 基本 Standard Premium 專用
壓縮事件中樞的大小 N/A 每個分割區 1 GB 每個分割區 250 GB 每個分割區 250 GB

如需了解其他配額和限制,請參閱事件中樞配額和限制

從壓縮主題取用事件

取用者端不需要變更,即可從壓縮事件中樞取用事件。 因此,您可以使用任何現有的取用者應用程式,從壓縮事件中樞取用資料。

下一步

  • 如需記錄壓縮運作方式概念的相關資訊,請參閱記錄壓縮