融合 kafka 休息 avrò 制作人

Question

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

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

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

Answer 1

是后者，当你使用客户端生成 kafka 时，它会要求一个键和一个值，这里的值是你的有效负载。 offset 和 partition 是 kafka 的内部值，每条记录都有一个，代表它在日志中的位置。由于未提供密钥，因此密钥为空。