0.8.x Java clients are supported for both producing and consuming with a 0.10.x broker.
If you are seeing data when you poll but it's just in a different format between 0.8 and 0.10 consumers then you might not be using the same (or compatible) serdes libraries to deserialize the messages. -hans Sent from my iPhone > On Feb 8, 2017, at 8:17 AM, Manikumar <manikumar.re...@gmail.com> wrote: > > Are you using new java consumer API? It is officially released as part of > 0.9 release. > 0.8.2.2 java consumer code may not be usable. You have to use old scala > consumer API. > > On Wed, Feb 8, 2017 at 9:35 PM, Jeffrey Zhang <xiuyan.zh...@salesforce.com> > wrote: > >> Any insight about these two versions, v0822 vs. v0101, of the Kafka >> behaviors as described below? >> Thanks >> >> Jeffrey >> >>> On Feb 7, 2017, at 7:42 PM, Jeffrey Zhang <xiuyan.zh...@salesforce.com> >> wrote: >>> >>> hi >>> >>> I have difficulty to have Kafka Client 0.8.2.2 to consume the messages >> on a Kafka Server 0.10.1.1, though I could produce message from this client >> 0.8.2.2 to the same server 0.10.1.1. >>> >>> My questions: >>> 1) could Kafka Client 0.8.2.2 be able to consume the messages from >> Server 0.10.1.1? >>> 1.1) If yes, would you pls provide an example? >>> 1.2) if no, do you have any work-around for these two versions to talk >> in the way I described above? >>> >>> Note that I see the returned object from poll method at 0.8.2.2 is quite >> different from that from 0.10.1.1... >>> >>> thanks for your help >>> Jeffrey >>> >>