融合 kafka rest avrò 制作人

Question

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

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

不知kafka上的message实际上是这种格式还是consumer端点添加了“key”和“partition”。如果它是前一个会很奇怪，因为在这种情况下，当您执行生产请求时响应有效负载 avro 架构不同（与 ACTUAL_PAYLOAD 匹配的架构）

Answer 1

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