[KAFKA-3036] Add up-conversion and down-conversion of ProducerRequest and FetchRequest to broker.

• Type: Sub-task
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.10.0.0
• Assignee: Jiangjie Qin
• Reporter: Jiangjie Qin
• Created: 23/Dec/15 08:00
• Updated: 24/Feb/16 06:49
• Resolved: 24/Feb/16 06:48

Description

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