kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yang <teddyyyy...@gmail.com>
Subject Re: java API equivalent of --from-beginning?
Date Fri, 06 Feb 2015 18:11:53 GMT
ah... thanks. I was looking at the latest github code
(commit f1ba4ff87e60a6dc06fb3d16e84fa94f8c4a7d9e )
and it doesn't show that line 181

I'll try it out

On Fri, Feb 6, 2015 at 5:37 AM, Joe Stein <joe.stein@stealth.ly> wrote:

> You have to delete the znode from zookeeper for your consumer group
>
> https://github.com/apache/kafka/blob/0.8.1/core/src/main/scala/kafka/consumer/ConsoleConsumer.scala#L181
>
> /*******************************************
>  Joe Stein
>  Founder, Principal Consultant
>  Big Data Open Source Security LLC
>  http://www.stealth.ly
>  Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
> ********************************************/
>
> On Fri, Feb 6, 2015 at 5:48 AM, Yang <teddyyyy123@gmail.com> wrote:
>
> > we are trying to achive the equivalent of
> > bin/kafka-console-consumer.sh
> >
> >
> > we tried " props.put("auto.offset.reset", "smallest");
> >
> > but it still doesn't work.
> >
> > how can I achieve --from-beginning in java code? thanks
> >
> > (we are using 8.1.1)
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message