rite a
> > simple
> > > Java client application that firstly calls 'seek' or 'seekToBeginning'
> to
> > > reset offsets to what you expect and then invoke commitSync to commit
> the
> > > offsets.
> > >
> > >
> > >
y calls 'seek' or 'seekToBeginning'
> to
> > > reset offsets to what you expect and then invoke commitSync to commit
> the
> > > offsets.
> > >
> > >
> > >
> > > 发件人: Paul van der Linden
> > >
le
> > Java client application that firstly calls 'seek' or 'seekToBeginning' to
> > reset offsets to what you expect and then invoke commitSync to commit the
> > offsets.
> >
> >
> > ____
> > 发件人: Paul van der Li
: 2017年5月3日 18:28
> 收件人: users@kafka.apache.org
> 主题: Resetting offsets
>
> I'm trying to reset the offsets for all partitions for all topics for a
> consumer group, but I can't seem to find a working way.
>
> The command line tool provides a tool to remove a consumer gr
van der Linden
发送时间: 2017年5月3日 18:28
收件人: users@kafka.apache.org
主题: Resetting offsets
I'm trying to reset the offsets for all partitions for all topics for a
consumer group, but I can't seem to find a working way.
The command line tool provides a tool to remove a consumer grou
I'm trying to reset the offsets for all partitions for all topics for a
consumer group, but I can't seem to find a working way.
The command line tool provides a tool to remove a consumer group (which
would be fine in this occasion), but this is not working with the "new"
style consumer groups. I t
Reading offsets looks like it's compatible across 0.8.1 and 0.8.2.
However, we cannot use the update logic in ImportZkOffsets, since we want to
store offsets in the broker in 0.8.2.
It looks like SimpleConsumer.commitOffsets() would work with either version. Is
there a better way?
-Suren
See https://cwiki.apache.org/confluence/display/KAFKA/System+Tools
and check the following:
GetOffsetShell (not very accurate - will set your offsets to much smaller
values than you really need; we log offsets frequently in application logs
and get it from there)
ImportZkOffsets
Kind regards,
Mich
We are using the High Level Consumer API to interact with Kafka.
However, on restart in the case of failures, we want to be able to manually
reset offsets in certain situations.
What is the recommended way to do this?
Should we use the Simple Consumer API just for this restart case?
Ideally, it
