confluent kafka rest avrò производитель

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

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

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


apache-kafka confluent-platform
person edi    schedule 14.10.2016    source источник

Ответы (1)


arrow_upward
1
arrow_downward

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

person TheM00s3    schedule 15.10.2016
comment
@Ray Не забудьте отметить этот ответ как лучший ответ, если вы нашли его полезным. - person TheM00s3; 17.10.2016