Hi Gwen, Sorry, both the consumer and the broker are 0.8.2? A = Yes
So what's on 0.8.1? A = It works fine using 0.8.1 for server AND client. You probably know the consumer group of your application. Can you use the offset checker tool on that? A = Yes, I know from the consumer, and the offset checker gave me nothing about that group. Thanks, Ricardo On Sun, Feb 8, 2015 at 1:19 PM, Gwen Shapira <gshap...@cloudera.com> wrote: > Sorry, both the consumer and the broker are 0.8.2? > > So what's on 0.8.1? > > I seriously doubt downgrading is the solution. > > You probably know the consumer group of your application. Can you use the > offset checker tool on that? > > Gwen > > On Sun, Feb 8, 2015 at 9:01 AM, Ricardo Ferreira < > jricardoferre...@gmail.com> wrote: > >> 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 >>>> >>> >>> >> >
