Блог

Я использую confluent kafka-rest для создания сообщения avro, когда я использую конечную точку rest для его использования, формат возврата выглядит следующим образом.

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

Интересно, сообщение в kafka на самом деле является этим форматом или «ключ» и «раздел» добавляются конечной точкой потребителя. Было бы странно, если бы это было первое, поскольку в этом случае схема avro полезной нагрузки ответа не совпадает при выполнении запроса на создание (схема, соответствующая ACTUAL_PAYLOAD)

Позже, когда вы создаете kafka с помощью клиента, он запрашивает ключ и значение, значение здесь является вашей полезной нагрузкой. Смещение и разделение являются внутренними значениями для kafka, и каждая запись имеет одно значение, представляющее ее позицию в журнале. Ключ равен нулю, поскольку ключ не был предоставлен.