Jiangjie Qin created KAFKA-3036: ----------------------------------- Summary: Add up-conversion and down-conversion of ProducerRequest and FetchRequest to broker. Key: KAFKA-3036 URL: https://issues.apache.org/jira/browse/KAFKA-3036 Project: Kafka Issue Type: Sub-task Reporter: Jiangjie Qin Assignee: Jiangjie Qin
This ticket will implement the necessary up-conversion and down-conversion for protocol migration in KIP-31 and KIP-32. https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+CreateTime+and+LogAppendTime+to+Kafka+message As a short summary: 1. When message.format.version=0, down-convert MessageAndOffset v1 to MessageAndOffset v0 when receives ProduceRequest v2 2. When message.format.version=1 a. up-convert MessageAndOffset v0 to MessageAndOffset v1 when receives ProduceRequest v1 b. down-convert MessageAndOffst v1 to MessageAndOffset v0 when receives FetchRequest v1 -- This message was sent by Atlassian JIRA (v6.3.4#6332)