search

bsm / sarama-cluster

Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
MIT License
1.01k stars 222 forks source link

Add custom offsets feature #268

Closed gqcn closed 6 years ago

gqcn commented 6 years ago

This extends MarkOffset/MarkPartitionOffset and ResetPartitionOffset/ResetPartitionOffset methods, using which can fetch consumed offset from Kafka.

dim commented 6 years ago

Sorry, really not a fan of this. You shouldn't be able to commit offsets that your consumer has no ownership of. I also think Kafka may reject that, if you try to update a non-subscribed offset with your member/generation IDs