Kafka consumer offset reset

[Jakub Stransky <st...@gmail.com>]

Hello,

just recently migrated to using Kafka 0.10.1.0

I would like to reset position for some consumers. I went through
documentation and couldn't spot it how to achieve that. All what I got is
that v 10 reduces usage of zookeeper and clients have possibility to use
different storage for maintaining the offsets.

Could someone more experienced elaborate a bit on this topic?

Thanks
jakub

Re: Kafka consumer offset reset

[Stevo Slavić <ss...@gmail.com>]

Hello Jakub,

Maybe you're interested in feature that's not yet available but is being
proposed and discussed (on dev ML) for future - see
https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+tooling

Kind regards,
Stevo Slavic.

On Tue, Mar 21, 2017 at 4:43 PM, Robert Quinlivan <rq...@signal.co>
wrote:

> What offset do you want to reset them to? The easier way to adjust offsets
> in 0.10 is to attach a consumer for the target topic-partition and seek to
> the position you desire and commit that new offset.
>
> On Tue, Mar 21, 2017 at 9:56 AM, Jakub Stransky <st...@gmail.com>
> wrote:
>
> > Hello,
> >
> > just recently migrated to using Kafka 0.10.1.0
> >
> > I would like to reset position for some consumers. I went through
> > documentation and couldn't spot it how to achieve that. All what I got is
> > that v 10 reduces usage of zookeeper and clients have possibility to use
> > different storage for maintaining the offsets.
> >
> > Could someone more experienced elaborate a bit on this topic?
> >
> > Thanks
> > jakub
> >
>
>
>
> --
> Robert Quinlivan
> Software Engineer, Signal
>

Re: Kafka consumer offset reset

[Robert Quinlivan <rq...@signal.co>]

What offset do you want to reset them to? The easier way to adjust offsets
in 0.10 is to attach a consumer for the target topic-partition and seek to
the position you desire and commit that new offset.

On Tue, Mar 21, 2017 at 9:56 AM, Jakub Stransky <st...@gmail.com>
wrote:

> Hello,
>
> just recently migrated to using Kafka 0.10.1.0
>
> I would like to reset position for some consumers. I went through
> documentation and couldn't spot it how to achieve that. All what I got is
> that v 10 reduces usage of zookeeper and clients have possibility to use
> different storage for maintaining the offsets.
>
> Could someone more experienced elaborate a bit on this topic?
>
> Thanks
> jakub
>



-- 
Robert Quinlivan
Software Engineer, Signal