[ https://issues.apache.org/jira/browse/KAFKA-2512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jiangjie Qin updated KAFKA-2512: -------------------------------- Summary: Add version and magic byte verification on broker and clients. (was: KafkaConsumer and ZookeeperConsumerConnector should verify the magic byte.) > Add version and magic byte verification on broker and clients. > -------------------------------------------------------------- > > Key: KAFKA-2512 > URL: https://issues.apache.org/jira/browse/KAFKA-2512 > Project: Kafka > Issue Type: Bug > Reporter: Jiangjie Qin > Assignee: Jiangjie Qin > > Both new and old consumer do not verify the magic byte of a message when it > consumes a message. This is needed for protocol upgrade so the consumer can > provide correct information to user. -- This message was sent by Atlassian JIRA (v6.3.4#6332)