Hey Jorge, Thanks for the KIP. I have some quick comments:
- Should we allow user to use wildcard to reset offset of all groups for a given topic as well? - Should we allow user to specify timestamp per topic partition in the json file as well? - Should the script take some credential file to make sure that this operation is authenticated given the potential impact of this operation? - Should we provide constant to reset committed offset to earliest/latest offset of a partition, e.g. -1 indicates earliest offset and -2 indicates latest offset. - Should we allow dynamic change of the comitted offset when consumer are running, such that consumer will seek to the newly committed offset and start consuming from there? BTW, I guess more people just write their own program which starts a consumer and commits offset instead of re-deploying application as suggested in the motivation section. I agree that having a ready-to-use script will make it easier. Thanks, Dong On Tue, Feb 7, 2017 at 6:43 PM, Jorge Esteban Quilcate Otoya < quilcate.jo...@gmail.com> wrote: > Hi all, > > I would like to propose a KIP to Add a tool to Reset Consumer Group > Offsets. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-122% > 3A+Add+a+tool+to+Reset+Consumer+Group+Offsets > > Please, take a look at the proposal and share your feedback. > > Thanks, > Jorge. >
