kafka icon indicating copy to clipboard operation
kafka copied to clipboard

KAFKA-19244: Add support for kafka-streams-groups.sh options (reset-offsets) [1/N]

Open aliehsaeedii opened this issue 8 months ago • 0 comments

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 [email protected], Bill Bejeck [email protected]

aliehsaeedii avatar May 05 '25 23:05 aliehsaeedii