/usr/bin/kafka-streams-groups.sh

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 <String: server to   REQUIRED: The server(s) to connect to.
  connect to>
--by-duration <String: duration>        Reset offsets by duration from current
                                          timestamp. Format: 'PnDTnHnMnS'
--command-config <String: command       Property file containing configs to be
  config property file>                   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 <String>        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 <String: path to CSV file>  Reset offsets to values defined in CSV
                                          file.
--group <String: group id>              The streams group id.
--help                                  Print usage information.
--input-topic <String: 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 <Long: number-of-offsets>    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 <Long: timeout (ms)>          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 <String: 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 <Long: 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.