kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Stein <joe.st...@stealth.ly>
Subject Re: java API equivalent of --from-beginning?
Date Fri, 06 Feb 2015 13:37:24 GMT
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