操作步驟

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版數據時支持的網絡連接方式。 默認網絡 自建公網	默認網絡
   專有網絡VPC	選擇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字段包含的參數解釋如下表所示。