1.6.3. 消息格式
使用 /topics 端点发送消息时,您可以在请求正文中输入消息有效负载,在 records 参数中输入。
records 参数可以包含任何这些可选字段:
-
Message
headers -
Message
key -
消息
值 -
目的地
分区
到 /topics 的 POST 请求示例
curl -X POST \
http://localhost:8080/topics/my-topic \
-H 'content-type: application/vnd.kafka.json.v2+json' \
-d '{
"records": [
{
"key": "my-key",
"value": "sales-lead-0001"
"partition": 2
"headers": [
{
"key": "key1",
"value": "QXBhY2hlIEthZmthIGlzIHRoZSBib21iIQ=="
}
]
},
]
}'
- 1
- 二进制格式的标头值,并编码为 Base64。