1.6. 对 Kafka Bridge 的请求

API 请求和响应正文始终编码为 JSON。

嵌入式数据格式是为每个消费者设置的，如下一节中所述。

如果 POST 请求带有空的正文，则一定不能设置 Content-Type。可以使用空正文来创建具有默认值的消费者。

嵌入式数据格式是通过 HTTP 传输的 Kafka 消息的格式，使用 Kafka Bridge 将生产者传输到消费者。支持两种嵌入式数据格式：JSON 和二进制。

当使用 /consumers/groupid 端点创建消费者时，POST 请求正文必须指定 JSON 或二进制的嵌入式数据格式。这在 format 字段中指定，例如：

{
  "name": "my-consumer",
  "format": "binary", 
  # ...
}

{
  "name": "my-consumer",
  "format": "binary", 

  # ...
}

创建消费者时指定的嵌入式数据格式必须与它将使用的 Kafka 信息的数据格式匹配。

如果您选择指定二进制嵌入的数据格式，后续的制作者请求必须在请求正文中提供二进制数据作为 Base64 编码的字符串。例如，当使用 /topics/topicname 端点发送消息时，records.value 必须使用 Base64 编码：

{
  "records": [
    {
      "key": "my-key",
      "value": "ZWR3YXJkdGhldGhyZWVsZWdnZWRjYXQ="
    },
  ]
}

{
  "records": [
    {
      "key": "my-key",
      "value": "ZWR3YXJkdGhldGhyZWVsZWdnZWRjYXQ="
    },
  ]
}

制作者请求还必须提供与嵌入式数据格式对应的 Content-Type 标头，如 Content-Type: application/vnd.kafka.binary.v2+json。

使用 /topics 端点发送消息时，您可以在请求正文中输入消息有效负载，在 records 参数中输入消息有效负载。

records 参数可以包含这些可选字段：

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==" 
              }
            ]
        }
    ]
}'

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==" 

              }
            ]
        }
    ]
}'

创建消费者后，所有后续 GET 请求都必须以以下格式提供 Accept 标头：

Accept: application/vnd.kafka.EMBEDDED-DATA-FORMAT.v2+json

Accept: application/vnd.kafka.EMBEDDED-DATA-FORMAT.v2+json

EMBEDDED-DATA-FORMAT 是 json 或 二进制。

例如，当使用 JSON 的嵌入式数据格式检索订阅消费者的记录时，请包含此 Accept 标头：

Accept: application/vnd.kafka.json.v2+json

Accept: application/vnd.kafka.json.v2+json