http://kafka.apache.org/081/documentation.html#highlevelconsumerapi
On Thu, Feb 9, 2017 at 6:56 AM, Jeffrey Zhang <xiuyan.zh...@salesforce.com> wrote: > Manikumar, can you give a pointer where to find "old scala consumer API"? > thanks > Jeffrey > > On Wed, 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 > > > > > > > > > >
