kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Joseph M'BIMBI-BENE" <joseph.mbi...@gmail.com>
Subject Re: resetting consumer group offset to earliest and to-latest not working
Date Mon, 03 Sep 2018 13:32:55 GMT
After checking at work, it seems to work fine.

The resetting would fail because of other consumers joining the group due
to deployment config errors and i would afterwards check that everything is
fine using the incorrect command, forgetting the "-execute".

Thank you

On Sat, 1 Sep 2018 at 15:15, Joseph M'BIMBI-BENE <joseph.mbimbi@gmail.com>
wrote:

> Oh thank you for pointing that out, in the screenshot i sent i indeed
> forgot that parameter.
> It was an attempt to reproduce an error encountered on another system
>
> On that system i can see that the source code includes the --execute
> command.
> I will send you logs, screenshots etc. using the original system when i'm
> back at work.
>
> Thank you
>
> On Sat, 1 Sep 2018 at 15:02, Patrik Kleindl <pkleindl@gmail.com> wrote:
>
>> Hello
>> Did you add --execute to the command?
>> Which command did you use?
>> Best regards
>> Patrik
>>
>> > Am 01.09.2018 um 14:54 schrieb Joseph M'BIMBI-BENE <
>> joseph.mbimbi@gmail.com>:
>> >
>> > Hello everyone,
>> >
>> > Hopefully this is the appropriate mailing list for my message.
>> > When i am trying to reset the offset of some consumer group, i get some
>> echo telling me that the offset has indeed been reset to earliest or
>> latest, but checking right after, the offset is still at its previous
>> position, and restarting the consumers on the group, they indeed continue
>> to consume message even after issuing the command to reset the offsets of
>> the partitions to the latest offset.
>> >
>> > I am Using Kafka 1.1.1 for scala 2.11, and i will put a screenshot of
>> the terminal if that could help you help me.
>> >
>> > Thank you in advance. Best regards
>>
>

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