I have a 0.8.1 high level consumer working fine with 0.8.2 server. Few of them actually :) AFAIK the API did not change.
Do you see any error messages? Do you have timeout configured on the consumer? What does the offset checker tool say? On Fri, Feb 6, 2015 at 4:49 PM, Ricardo Ferreira <jricardoferre...@gmail.com > wrote: > Hi, > > I had a client running on Kafka 0.8.1 using the High-Level consumer API > working fine. > > Today I updated my Kafka installation for the 0.8.2 version (tried all > versions of Scala) but the consumer doesn't get any messages. I tested > using the kafka-console-consumer.sh utility tool and works fine, only my > Java program that not. > > Did I miss something? I heard that the API changed, so I'd like to know if > someone can share a simple client with me. > > Please, respond directly to me or just reply all because I am not currently > subscribed to the group. > > Thanks, > > Ricardo Ferreira >
