自訂事件來源訊息佇列Kafka版

操作步驟

1. 登入事件匯流排EventBridge控制台，在左側導覽列，單擊事件匯流排。
2. 在頂部功能表列，選擇地區，在事件匯流排頁面，單擊目標匯流排名稱。
3. 在左側導覽列，單擊事件來源。

4. 在事件源頁面，單擊添加事件源。

5. 在添加自定义事件源面板，輸入名称和描述，將事件提供方選擇為云消息队列 Kafka 版，配置以下參數，然後單擊确认。

   參數	說明	樣本
   kafka 執行個體	選擇前提條件中已建立的雲訊息佇列 Kafka 版執行個體。	alikafka_post-cn-20p31hkm****
   Topic	選擇當前執行個體中的Topic。	test_topic
   Group ID	快速建立：自動建立以GID_EVENTBRIDGE_xxx命名的Group ID。 使用已有：選擇當前執行個體中已建立的Group，請不要與已有業務的Group混用，以免影響已有的訊息收發。	test_group
   並發配額（消費者數）	當前Group中的Consumer數量。	1
   消費位點	開始消費的位置。 最新位點：從最新位點開始消費。 最早位點：從最初位點開始消費。	最新位點
   網路設定	事件匯流排EventBridge整合雲訊息佇列 Kafka 版資料時支援的網路連接方式。 基礎網路 自建公網	基礎網路
   Virtual Private Cloud	選擇VPC ID。當網路設定選擇為自建公網時需要配置此參數。	vpc-bp17fapfdj0dwzjkd****
   交換器	選擇vSwitch ID。當網路設定選擇為自建公網時需要配置此參數。	vsw-bp1gbjhj53hdjdkg****
   安全性群組	選擇安全性群組。當網路設定選擇為自建公網時需要配置此參數。	vpc-bp1syi9jrmx3x****

事件樣本

{
    "id":"94ebc15f-f0db-4bbe-acce-sf6778fs****",
    "source":"acs:alikafka",
    "specversion":"1.0",
    "type":"alikafka:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:alikafka:cn-hangzhou:123456789098****:topics/TopicName",
    "time":"2022-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2022-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "InstanceId":"alikafka_post-cn-****",
        "ConsumerGroup":"GID-test-group",
        "Topic":"test-topic",
        "RegionId":"cn-hangzhou",
        "OffsetReset":"earliest",
        "MaximumTasks":1,
        "Network":"PublicNetwork",
        "SecurityGroupId":"vpc-bp1syi9jrmx3x****",
        "VpcId":"vpc-bp1syi9jrmx3xwnw****",
        "VSwitchIds":"vsw-bp1q0tnb71j8qzxg****"
    }
}

CloudEvents規範中定義的參數解釋，請參見事件概述。

data欄位包含的參數解釋如下表所示。