1.6.2. 嵌入式数据格式

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

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

{
  "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。