GitHub user mjsax opened a pull request:
https://github.com/apache/kafka/pull/4215
Kafka 6121 restore global consumer handle reset
- set auto.offset.reste to "none" for restore and global consumer
- handle InvalidOffsetException for restore and global consumer
- add corresponding tests
- some minor cleanup
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mjsax/kafka
kafka-6121-restore-global-consumer-handle-reset
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/4215.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #4215
----
commit 5acd77423a67dcd850f22bc92114a67d81449f26
Author: Matthias J. Sax <matth...@confluent.io>
Date: 2017-11-13T21:39:04Z
KAFKA-6121: Restore and global consumer should not use auto.offset.reset
commit 514fb5a4bfce960ad792ae0317e4bb41ef42adf3
Author: Matthias J. Sax <matth...@confluent.io>
Date: 2017-11-15T04:09:33Z
adding test and fixing code
----
---
