Hi Dave, On Fri, Jan 15, 2016 at 2:04 AM, Dave Peterson <[email protected]> wrote:
> I was trying to upgrade an 0.8.2.1 broker cluster to 0.9.0.0 by following > the instructions here: > > http://kafka.apache.org/documentation.html#upgrade > > After upgrading one broker, with inter.broker.protocol.version=0.8.2.X > set, I get ACK error 2 (InvalidMessage) when I try to send produce > requests. I haven't seen other reports of this issue yet. Also, we have a system test that covers this scenario: https://github.com/apache/kafka/blob/trunk/tests/kafkatest/tests/upgrade_test.py Just to double-check, what is the version of the producer that you are using to send produce requests to the 0.9.0.0 broker when you get the error? Ismael
