Hi Gwen, Thanks for the response.
In my case, I have both consumer application and the server versions in 0.8.2, Scala 2.10. No errors are thrown, and my *zookeeper.session.timeout.ms <http://zookeeper.session.timeout.ms>* property is set to 500, although I tried 5000 and also didn't worked. I checked the offset checker tool, but it asks for a group in which I don't know which group the kafka-console-producer is using. I tried the consumer group but it gave the following message: Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/test-consumer-group/offsets/test/0. Perhaps the solution is downgrade the consumer libs to 0.8.1? Thanks, Ricardo On Sun, Feb 8, 2015 at 11:27 AM, Gwen Shapira <gshap...@cloudera.com> wrote: > 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 >> > >
