合流卡夫卡休息avr“生产者”

Question

我使用confluent kafka-rest生成avro消息，当我使用rest端点使用它时，返回格式如下所示。

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

我想知道kafka中的消息实际上是这种格式，或者"key“和”分区“是由使用者端点添加的。如果是前者，就会很奇怪，因为在本例中，当您执行生产请求(匹配ACTUAL_PAYLOAD的模式)时，响应有效载荷avro模式是不一样的。

Answer 1

后者，当您使用客户端向kafka生产时，它要求一个键和一个值，值就是您在这里的有效负载。偏移量和分区是kafka的内部值，每个记录都有一个，它在日志中表示其位置。该键为空，因为没有提供任何键。