This tool helps to list, describe, delete and manage the offsets of streams groups. Option Description ------ ----------- --all-groups Apply to all streams groups. --all-input-topics Consider all input topics used in the topology of the group. Supported operations: delete-offsets, reset- offsets. --bootstrap-server --by-duration Reset offsets by duration from current timestamp. Format: 'PnDTnHnMnS' --command-config passed to Admin Client. --delete Delete topic partition offsets and ownership information for one or more streams groups. --delete-all-internal-topics Delete all internal topics linked to the streams group. Supported operations: reset-offsets, delete. With reset-offsets, this option is applicable only when --execute is used. --delete-internal-topic Delete specified internal topic of the streams group. Supported operation: reset-offsets.This option is applicable only when --execute is used. --delete-offsets Delete offsets of streams group. Supports one streams group at a time, and multiple topics. --describe Describe streams group and list offset lag related to given group. --dry-run Only show results without executing changes on streams group. Supported operation: reset-offsets. --execute Execute the offset reset operation. Supported operation: reset-offsets. --export Generate offset reset information in CSV format for export to a file. Supported operation: reset-offsets. --from-file Reset offsets to values defined in CSV file. --group The streams group id. --help Print usage information. --input-topic The input topic whose committed offset should be deleted or reset. In -- reset-offsets case, partitions can be specified using this format: `topic:0,1,2`, where 0,1,2 are the partitions to be included. Multiple input topics can be specified. Supported operations: delete- offsets, reset-offsets. --list List all streams groups. --members Describe members of the group. This option may be used with the -- describe option only. --offsets Describe the group and list all topic partitions in the group along with their offset information.This is the default sub-action and may be used with the --describe option only. --reset-offsets Reset offsets of streams group. The instances should be inactive. Has 2 execution options: --dry-run to plan which offsets to reset, and -- execute to update the offsets. If you use --execute, all internal topics linked to the group will also be deleted. Additionally, the --export option can be used to generate the offsets in CSV format for export to a file. You must choose one of the following reset specifications: --to-datetime, --by-duration, --to-earliest, --to- latest, --shift-by, --from-file, -- to-current, --to-offset. To define the scope, use --all-input- topics or --input-topic. The scope must be specified unless you use -- from-file. Fails if neither --dry-run nor -- execute is specified. --shift-by Reset offsets shifting current offset by 'n', where 'n' can be positive or negative. --state [String] When specified with --list, it displays the state of all groups. It can also be used to list groups with specific states. Valid values are Empty, NotReady, Stable, Assigning, Reconciling, and Dead. --timeout The timeout that can be set for some use cases. For example, it can be used when describing the group to specify the maximum amount of time in milliseconds to wait before the group stabilizes. (default: 30000) --to-current Reset offsets to current offset. --to-datetime Reset offsets to offset from datetime. Format: 'YYYY-MM-DDThh:mm:ss.sss' --to-earliest Reset offsets to earliest offset. --to-latest Reset offsets to latest offset. --to-offset Reset offsets to a specific offset. --topology Describe the topology of the streams group, as recorded by the broker's topology description plugin. This option may be used with the '-- describe' option only. --verbose Use with --describe --state to show group epoch and target assignment epoch. Use with --describe --members to show for each member the member epoch, target assignment epoch, current assignment, target assignment, and whether member is still using the classic rebalance protocol. Use with --describe --offsets and -- describe to show leader epochs for each partition. --version Display Kafka version.