mirror of https://github.com/apache/kafka.git
a797d644bc
This PR implements all the options for `--reset-offset`, (supports `--execute`, `--dry-run`, `--export`). Includes unit and integration tests. - --reset-offsets --input-topic String: topics --shift-by Long - --reset-offsets --input-topic String: topics --to-offset Long - --reset-offsets --input-topic String: topics -to-latest - --reset-offsets --input-topic 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-topic 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 Reviewers: Lucas Brutschy <lbrutschy@confluent.io>, Bill Bejeck <bill@confluent.io> |
||
|---|---|---|
| .. | ||
| clients-integration-tests/src/test | ||
| src | ||
| .gitignore | ||