Hi Hans, thanks for your reply.
Here is what I see -
for the Kafka client v0.8.2.2, the consumer.poll method returns an object
of Map<String, ConsumerRecords> while it returns ConsumerRecords from Kafka
Server v0.10.1.1.
that is why Kafka client v0.8.2.2 now does not work with my Kafka Kafka
Server v0.10.1.1.
Were you saying that you have a way to change the returned format for
consumer.poll for v0.8.2.2?
If yes, pls advice how I could do it.
regarding Deserializer, I use the following
from kafka-clients-0.8.2.2.jar. How to change it?
props.put("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer","org.apache.kafka.common.serialization.StringDeserializer");
thanks a lot.
Jeffrey
On Wed, Feb 8, 2017 at 8:46 AM, <h...@confluent.io> wrote:
> 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
> >>>
> >>
>
