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

This tool helps to list, describe, delete and manage the offsets of share groups.
Option                                  Description
------                                  -----------
--all-groups                            Apply to all share groups.
--all-topics                            Apply to all topics. Supported
                                          operation: reset-offsets.
--bootstrap-server <String: server to   REQUIRED: The server(s) to connect to.
  connect to>
--command-config <String: command       Property file containing configs to be
  config property file>                   passed to Admin Client.
--delete                                Delete share group.
--delete-offsets                        Delete offsets of share group.
                                          Supports one share group at a time,
                                          and multiple topics.
--describe                              Describe share group, members and
                                          offset information.
--dry-run                               Output offset reset information
                                          without executing the operation.
                                          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 share group id.
--help                                  Print usage information.
--list                                  List all share 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 share group. Supports
                                          one share group at a time, and
                                          instances must be inactive.
                                        Has 2 execution options: --dry-run to
                                          plan which offsets to reset, and --
                                          execute to reset the offsets.
                                        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,
                                          --to-earliest, --to-latest, --from-
                                          file, --to-current, --to-offset.
                                        To define the scope, use --all-topics
                                          or --topic. The scope must be
                                          specified unless you use --from-file.
                                        Fails if neither --dry-run nor --
                                          execute is specified.
--state [String]                        When specified with --describe, it
                                          displays the state of the group.
                                        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, Stable 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.
--topic <String: topic>                 The topic whose offset information
                                          should be deleted or reset. When
                                          resetting offsets, partitions can be
                                          specified using this format: `topic:
                                          0,1,2`, where 0,1,2 are the
                                          partitions to be included.
--verbose                               Provide additional information, if
                                          any, when describing the group. This
                                          option may be used with the --
                                          describe option only.
--version                               Display Kafka version.