Versions Compared

Old Version 3

changes.mady.by.user Vahid Hashemian

Saved on

compared with

New Version 4

changes.mady.by.user Vahid Hashemian

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

This option of the command returns information on only active members of the group with assigned partitionsoffset and consumer information for each topic partition in the group. This is how the output of the example above would look like:

Code Block
languagebash
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
Note: This will only show information about consumers that use the Java consumer API (non-ZooKeeper-based consumers).
TOPIC                          PARTITION  CURRENT-OFFSET  LOG-END-OFFSET  LAG        CONSUMER-ID                                       HOST                           CLIENT-ID
my-topic                       1          30857           118320          87463      consumer2-5d3a62da-abe1-427d-a9e9-4962c35f2dae    /127.0.0.1                     consumer2
my-topic                       2          30857           118320          87463      consumer3-ad71338d-d379-4cff-be2d-1e3971f32f51    /127.0.0.1                     consumer3
my-topic                       0          31357           118320          86963      consumer1-5e864292-bef0-45f1-9b96-ea56943609e7    /127.0.0.1                     consumer1
my-other-topic                 1          6895            6895            0          -                                                 -                              -
my-other-topic                 0          6894            6894            0          -                                                 -                              -

--describe --members

A new option --members is introduced that is allowed with --describe only and returns info about active members of the group along with their assigned topic partitions:

...