kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Marko Bonaći <marko.bon...@sematext.com>
Subject Re: How to reset a consumer-group's offset in kafka 0.9?
Date Tue, 29 Dec 2015 15:46:40 GMT
I was refering to Dana Powers's answer in the link I posted (to use a
client API). You can find an example here:
http://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html

Marko Bonaći
Monitoring | Alerting | Anomaly Detection | Centralized Log Management
Solr & Elasticsearch Support
Sematext <http://sematext.com/> | Contact
<http://sematext.com/about/contact.html>

On Tue, Dec 29, 2015 at 4:41 PM, Stevo Slavić <sslavic@gmail.com> wrote:

> Then I guess @Before test, explicitly commit offset of 0.
>
> There doesn't seem to be a tool for committing offset, only for
> checking/fetching current offset (see
> http://kafka.apache.org/documentation.html#operations )
>
> On Tue, Dec 29, 2015 at 4:35 PM, Han JU <ju.han.felix@gmail.com> wrote:
>
> > Hi Stevo,
> >
> > But by deleting and recreating the topic, do I remove also the messages
> > ingested?
> > My use case is that I ingest prepared messages once and run consumer
> tests
> > multiple times, between each test run I reset the consumer group's offset
> > so that each run starts from the beginning and consumers all the
> messages.
> >
> > 2015-12-29 16:19 GMT+01:00 Stevo Slavić <sslavic@gmail.com>:
> >
> > > Have you considered deleting and recreating topic used in test?
> > > Once topic is clean, read/poll once - any committed offset should be
> > > outside of the range, and consumer should reset offset.
> > >
> > > On Tue, Dec 29, 2015 at 4:11 PM, Han JU <ju.han.felix@gmail.com>
> wrote:
> > >
> > > > Hello,
> > > >
> > > > For local test purpose I need to frequently reset offset for a
> consumer
> > > > group. In 0.8 I just delete the consumer group's zk node under
> > > > `/consumers`. But with the redesign of the 0.9, how could I achieve
> the
> > > > same thing?
> > > >
> > > > Thanks!
> > > >
> > > > --
> > > > *JU Han*
> > > >
> > > > Software Engineer @ Teads.tv
> > > >
> > > > +33 0619608888
> > > >
> > >
> >
> >
> >
> > --
> > *JU Han*
> >
> > Software Engineer @ Teads.tv
> >
> > +33 0619608888
> >
>

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