{"specversion":"1.0","id":"13a3f42d-7258-4ada-da6d-023a333b4662","type":"connector:kafka","source":"ckafka.cloud.tencent","subjuect": "qcs::ckafka:ap-guangzhou:uin/1250000000:ckafkaId/uin/1250000000/ckafka-123456","time":"1615430559146","region":"ap-guangzhou","datacontenttype":"application/json;charset=utf-8","data":{"topic":"test-topic","Partition":1,"offset":37,"msgKey":"test","msgBody":"Hello from Ckafka again!"}}
参数 | 描述 |
topic | Ckafka 投递 Topic。 |
Partition | 事件源所在分区,一个 Topic 可以包含一个或者多个 Partition,CKafka 以 Partition 作为分配单位。 |
offset | 消费分组,指定消费区域。 |
msgKey | Ckafka 消息 Key。 |
msgBody | Ckafka 消息体。 |
本页内容是否解决了您的问题?