Sarama: How to set offset to a specified value in Initialization

Created on 12 Feb 2020 · 3Comments · Source: Shopify/sarama

value of c.Consumer.Offsets.Initial must be OffsetNewest or OffsetOldest.

But in some cases, I need to comsume message from a specified offset.

i read the code but have not found method to solution my problem.

somebody who knows help me..thanks..

sorry for my poor english :(

Source

blackfox1983

Most helpful comment

@blackfox1983 your English is great, don't worry about that.

Regarding the question, one importan thing from @dnwe response, is that this is only supported by the low level consumer and it's not supported by ConsumerGroups

d1egoaz on 12 Feb 2020

👍3

All 3 comments

@blackfox1983 I think you are looking for this?https://github.com/Shopify/sarama/blob/6fb86a44d5915dcfd42af71a4c99674bb55650ca/consumer.go#L60-L64

dnwe on 12 Feb 2020

👍1

@blackfox1983 your English is great, don't worry about that.

Regarding the question, one importan thing from @dnwe response, is that this is only supported by the low level consumer and it's not supported by ConsumerGroups

d1egoaz on 12 Feb 2020

👍3

Also hope we can support set offset for ConsumerGroup

Or we can commit offset manually. (https://github.com/Shopify/sarama/issues/1570)