Hi Luke,

I could not get the consumer group to be inactive even when stopping all the consumers in the group.

Due this this being a production system i was unable to play to much with the kafka-consumer-groups --reset-offsets --shift-by command, so i had to run the following command:

kafka-run-class kafka.tools.UpdateOffsetsInZK latest (properties file containing kafka brokers) topicname

After doing this i consumed the missing offsets to file and the used kafka-producer to read from the file to the affected topic.

Hope this makes sense, i know there are better probably ways to do this but needed a quick and dirty fix :)

Thanks,

Chris

On 2022-08-29 07:16, Luke Chen wrote:

Hi Chris,

Great to hear you found a way to work around it now.
Could you share your solution here in case other people got stuck on the
same issue?

Thank you
Luke

On Fri, Aug 26, 2022 at 11:57 PM Chris Peart <ch...@peart.me.uk> wrote:

Thanks Luke,
The problem I was having was that the consumer group was not inactive even
with all the consumers stopped.
Managed to work around this now.

Many Thanks
Chris

On 25 Aug 2022, at 10:12 am, Luke Chen <show...@gmail.com> wrote:
Hi Chris,

is there a way to force the offset forward by an increment of 1 just for this topic?
kafka-consumer-groups.sh script has an option `--shift-by` to shift
 current

offset by 'n'.
I think this is what you are looking for.

Thank you
Luke

On Thu, Aug 25, 2022 at 4:25 PM Chris Peart <ch...@peart.me.uk> wrote:

Hi All,

I'm trying to reset a kafka offset for a topic in a consumer group, i
have stopped all the consumers using the consumer group but i'm still
receiving the message that the current state is stable.

Is there a way to put the consumer group to an inactive state after
stopping all the consumers or is there a way to force the offset forward
by an increment of 1 just for this topic?

Many Thanks,

Chris

Reply via email to