[ https://issues.apache.org/jira/browse/KAFKA-19244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alieh Saeedi updated KAFKA-19244: --------------------------------- Description: Implement the followings: * modify offsets: supports (-execute, {-}dry{-}-run, {{{}-export{}}}) * ** {{--reset-offsets --input-topics <String: topics> --shift-by Long}} * ** {{--reset-offsets --input-topics <String: topics> --to-offset Long}} * ** {{--reset-offsets --input-topics <String: topics> -to-latest}} * ** {{--reset-offsets --input-topics <String: topics> -to-earliest}} * ** {{--reset-offsets --all-input-topics --shift-by Long}} * ** {{--reset-offsets --all-input-topics --to-offset Long}} * ** {{--reset-offsets --all-input-topics -to-latest}} * ** {{--reset-offsets --all-input-topics -to-earliest}} * ** {{--reset-offsets --all-input-topics -to-earliest}} * ** {{--reset-offsets --from-file String:fileName}} * ** {{--reset-offsets --input-topics <String: topics> --by-duration String: duration}} * ** {{--reset-offsets --all-input-topics --by-duration String: duration}} * ** {{--reset-offsets --input-topics <String: topics> --to-datetime String: datetime}} * ** {{--reset-offsets --all-input-topics --to-datetime String: datetime}} * ** {{--reset-offsets --input-topics <String: topics> -to-current}} * ** {{--reset-offsets --all-input-topics -to-current}} * delete offsets: * ** {{--delete-offsets --all-input-topics}} * ** {{--delete-offsets --input-topics <String: topics>}} * ** {{--delete-offsets --from-file String:fileName}} * delete internal topics: * ** {{--delete --internal-topics}} * delete groups: * ** {{--delete --group}} was: Implement the followings: * modify offsets: supports ({{{}--execute{}}}, {{{}--dry-run{}}}, {{{}--export{}}}) ** {{--reset-offsets --input-topics <String: topics> --shift-by Long}} ** {{--reset-offsets --input-topics <String: topics> --to-offset Long}} ** {{--reset-offsets --input-topics <String: topics> -to-latest}} ** {{--reset-offsets --input-topics <String: topics> -to-earliest}} ** {{--reset-offsets --all-input-topics --shift-by Long}} ** {{--reset-offsets --all-input-topics --to-offset Long}} ** {{--reset-offsets --all-input-topics -to-latest}} ** {{--reset-offsets --all-input-topics -to-earliest}} ** {{--reset-offsets --all-input-topics -to-earliest}} ** {{--reset-offsets --from-file String:fileName}} ** {{--reset-offsets --input-topics <String: topics> --by-duration String: duration}} ** {{--reset-offsets --all-input-topics --by-duration String: duration}} ** {{--reset-offsets --input-topics <String: topics> --to-datetime String: datetime}} ** {{--reset-offsets --all-input-topics --to-datetime String: datetime}} ** {{--reset-offsets --input-topics <String: topics> -to-current}} ** {{--reset-offsets --all-input-topics -to-current}} * delete offsets: ** {{--delete-offsets --all-input-topics}} ** {{--delete-offsets --input-topics <String: topics>}} ** {{--delete-offsets --from-file String:fileName}} * delete internal topics: ** {{--delete --internal-topics}} * delete groups: ** {{--delete --group}} > Add support for kafka-streams-groups.sh options beyond list/describe group > (delete group, offset-related APIs) > -------------------------------------------------------------------------------------------------------------- > > Key: KAFKA-19244 > URL: https://issues.apache.org/jira/browse/KAFKA-19244 > Project: Kafka > Issue Type: Sub-task > Reporter: Alieh Saeedi > Assignee: Alieh Saeedi > Priority: Major > > Implement the followings: > * modify offsets: supports (-execute, {-}dry{-}-run, {{{}-export{}}}) > * > ** {{--reset-offsets --input-topics <String: topics> --shift-by Long}} > * > ** {{--reset-offsets --input-topics <String: topics> --to-offset Long}} > * > ** {{--reset-offsets --input-topics <String: topics> -to-latest}} > * > ** {{--reset-offsets --input-topics <String: topics> -to-earliest}} > * > ** {{--reset-offsets --all-input-topics --shift-by Long}} > * > ** {{--reset-offsets --all-input-topics --to-offset Long}} > * > ** {{--reset-offsets --all-input-topics -to-latest}} > * > ** {{--reset-offsets --all-input-topics -to-earliest}} > * > ** {{--reset-offsets --all-input-topics -to-earliest}} > * > ** {{--reset-offsets --from-file String:fileName}} > * > ** {{--reset-offsets --input-topics <String: topics> --by-duration String: > duration}} > * > ** {{--reset-offsets --all-input-topics --by-duration String: duration}} > * > ** {{--reset-offsets --input-topics <String: topics> --to-datetime String: > datetime}} > * > ** {{--reset-offsets --all-input-topics --to-datetime String: datetime}} > * > ** {{--reset-offsets --input-topics <String: topics> -to-current}} > * > ** {{--reset-offsets --all-input-topics -to-current}} > * delete offsets: > * > ** {{--delete-offsets --all-input-topics}} > * > ** {{--delete-offsets --input-topics <String: topics>}} > * > ** {{--delete-offsets --from-file String:fileName}} > * delete internal topics: > * > ** {{--delete --internal-topics}} > * delete groups: > * > ** {{--delete --group}} -- This message was sent by Atlassian Jira (v8.20.10#820010)