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 > > >
