Thanks for the feedback Matthias! The main idea is to use only 1 tool to reset offsets and don't replicate functionality between tools. Reset Offset (KIP-122) tool not only reset but support execute the reset but also export, import from files, etc. If we extend the current tool (kafka-streams-application-reset.sh) we will have to duplicate all this functionality also. Maybe another option is to move the current implementation into `kafka-consumer-group` and add a new command `--reset-offset-streams` with the current implementation functionality and add `--reset-offset` options for input topics. Does this make sense?
El lun., 26 jun. 2017 a las 23:32, Matthias J. Sax (<matth...@confluent.io>) escribió: > Jorge, > > thanks a lot for this KIP. Allowing the reset streams applications with > arbitrary start offset is something we got multiple requests already. > > Couple of clarification question: > > - why do you want to deprecate the current tool instead of extending > the current tool with the stuff the offset reset tool can do (ie, use > the offset reset tool internally) > > - you suggest to extend the offset reset tool to replace the stream > reset tool: how would the reset tool know if it is resetting a streams > applications or a regular consumer group? > > > > -Matthias > > > On 6/26/17 1:28 PM, Jorge Esteban Quilcate Otoya wrote: > > Hi all, > > > > I'd like to start the discussion to add reset offset tooling for Stream > > applications. > > The KIP can be found here: > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-171+-+Extend+Consumer+Group+Reset+Offset+for+Stream+Application > > > > Thanks, > > Jorge. > > > >
