[ https://issues.apache.org/jira/browse/KAFKA-3201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15159416#comment-15159416 ]
Anna Povzner commented on KAFKA-3201: ------------------------------------- Here is a set of tests: 1. Setup: Producer (0.8) → Kafka Cluster → Consumer (0.8) First rolling bounce: Set inter.broker.protocol.version = 0.8 and message.format.version = 0.8 Second rolling bonus, use latest (default) inter.broker.protocol.version and message.format.version 2. Setup: Producer (0.9) → Kafka Cluster → Consumer (0.9) First rolling bounce: Set inter.broker.protocol.version = 0.9 and message.format.version = 0.9 Second rolling bonus, use latest (default) inter.broker.protocol.version and message.format.version 3. Setup: Producer (0.9) → Kafka Cluster → Consumer (0.9) First rolling bounce: Set inter.broker.protocol.version = 0.9 and message.format.version = 0.9 Second rolling bonus: use inter.broker.protocol.version = 0.10 and message.format.version = 0.9 All three tests will be producing/consuming in the background; in the end the messages consumed will be validated; we will use a mix of producers: using compression and not using compression. [~becket_qin] I understand the test where message format changes on the fly is KAFKA-3202, so I will not do a third phase in setup 3 to move to 0.10 message format (because it will be covered in KAFKA-3202). Is my understanding correct? > Add system test for KIP-31 and KIP-32 - Upgrade Test > ---------------------------------------------------- > > Key: KAFKA-3201 > URL: https://issues.apache.org/jira/browse/KAFKA-3201 > Project: Kafka > Issue Type: Sub-task > Components: system tests > Reporter: Jiangjie Qin > Assignee: Anna Povzner > Fix For: 0.10.0.0 > > > This system test should test the procedure to upgrade a Kafka broker from > 0.8.x and 0.9.0 to 0.10.0 > The procedure is documented in KIP-32: > https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+Add+timestamps+to+Kafka+message -- This message was sent by Atlassian JIRA (v6.3.4#6332)