我使用汇合 kafka-rest 来生成 avro 消息，当我使用其余端点来使用它时，返回格式是这样的。
{
"key":null,
"value": {ACTUAL_PAYLOAD},
"partition":X,"offset":0
}
我想知道 kafka 中的消息实际上是这种格式，或者消费者端点添加了“密钥”和“分区”。如果是前者，那将会很奇怪，因为在这种情况下，当您执行与 ACTUAL_PAYLOAD 匹配的产品 request(schema 时，响应有效负载 avro 架构不同
1 回答
它是后者，当你使用客户端生成 kafka 时，它会要求输入一个 Key 和一个值，这里的值就是你的有效负载。偏移量和分区是 kafka 的内部值，每个记录都有一个，它表示它在日志中的位置。由于没有提供密钥，因此密钥为空。