franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.6+. Producing, consuming, transacting, administrating, etc.
BSD 3-Clause "New" or "Revised" License
1.61k
stars
158
forks
source link
Any way to assign only commited offsets on rebalance? #702
Hi, I'm new to franz and trying to implement the following behavior (looks like it's the default behavior of Sarama lib):
Once group rebalance has finished, assign only commited offsets, even if no partitions have been revoked from this particular consumer.
I'm using AutoCommitMarks option.
Hi, I'm new to franz and trying to implement the following behavior (looks like it's the default behavior of Sarama lib):
Once group rebalance has finished, assign only commited offsets, even if no partitions have been revoked from this particular consumer. I'm using
AutoCommitMarks
option.