[
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)