apache-kafka - 融合 kafka rest avrò 制作人

Question

我使用 confluent kafka-rest 生成 avro 消息，当我使用 rest 端点消费它时，返回格式是这样的。

{
    "key":null,
    "value": {ACTUAL_PAYLOAD},
    "partition":X,"offset":0
}

我想知道kafka中的消息实际上是这种格式还是消费者端点添加了“密钥”和“分区”。如果是前一个会很奇怪，因为在这种情况下，当您执行生产请求时响应有效负载 avro 模式是不同的（与 ACTUAL_PAYLOAD 匹配的模式）

Answer 1

后者，当您使用客户端生成 kafka 时，它会要求提供一个 Key 和一个值，该值是您的有效负载。偏移量和分区是 kafka 的内部值，每条记录都有一个，它代表它在日志中的位置。由于没有提供密钥，因此密钥为空。