Re: Should 0.8.3 consumers correctly function with 0.8.2 brokers?

on, >> no? >> >> On Thu, Apr 23, 2015 at 7:26 PM, Gwen Shapira >> wrote: >> >> > I didn't think 0.8.3 consumer will ever be able to talk to 0.8.2 >> > broker... there are some essential pieces that are missing in 0.8.2 >> > (Coordinator, Heartb

Should 0.8.3 consumers correctly function with 0.8.2 brokers?

Currently the clients consumer (trunk) sends offset commit requests of version 2. The 0.8.2 brokers fail to handle this particular request with a: java.lang.AssertionError: assertion failed: Version 2 is invalid for OffsetCommitRequest. Valid versions are 0 or 1. I was able to make this work via

[jira] [Commented] (KAFKA-2121) prevent potential resource leak in KafkaProducer and KafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-2121?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14510117#comment-14510117 ] Sean Lydon commented on KAFKA-2121: --- While this does resolve https://issues.apache