[ https://issues.apache.org/jira/browse/KAFKA-3401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15195757#comment-15195757 ]
Jiangjie Qin edited comment on KAFKA-3401 at 3/15/16 5:39 PM: -------------------------------------------------------------- [~ijuma] You are right. We should only change the message format version for the topic for 0.10.0.0 consumer. [~enothereska] Sorry about the confusion. I think this exception is expected. was (Author: becket_qin): [~ijuma] You are right. We should only change the message format version for the topic for 0.10.0.0 consumer. Sorry about the confusion. > Message format change on the fly breaks 0.9 consumer > ---------------------------------------------------- > > Key: KAFKA-3401 > URL: https://issues.apache.org/jira/browse/KAFKA-3401 > Project: Kafka > Issue Type: Bug > Affects Versions: 0.10.0.0 > Reporter: Eno Thereska > Assignee: Jiangjie Qin > Priority: Blocker > Fix For: 0.10.0.0 > > Attachments: 2016-03-15--009.zip > > > The new system test as part of KAFKA-3202 reveals a problem when the message > format is changed on the fly. When the cluster is using 0.10.x brokers and > producers and consumers use version 0.9.0.1 an error happens when the message > format is changed on the fly to version 0.9: > {code} > Exception: {'ConsoleConsumer-worker-1': Exception('Unexpected message format > (expected an integer). Message: null',)} > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)