DUE TO SPAM, SIGN-UP IS DISABLED. Goto Selfserve wiki signup and request an account.
...
| Code Block |
|---|
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --state --verbose GROUP COORDINATOR (ID) ASSIGNMENT-STRATEGY STATE GROUP-EPOCH TARGET-ASSIGNMENT-EPOCH #MEMBERS my-group localhost:61316 (0) uniform Stable 13 13 12 |
--describe --members --verbose
Show the member level information. Add CURRENT-EPOCH, TARGET-EPOCH, TARGET-ASSIGNMENT, and IS-CLASSIC UPGRADED information. The CURRENT-EPOCH means member epoch. Change ASSIGNMENT to CURRENT-ASSIGNMENT. For both classic and consumer groups, the ASSIGNMENT value format will change from "(0,1), (0,1)" to "my_topic:0,1;new_topic:0,1". The original format only shows sorted partition numbers for each topic. The new format adds the topic name. The UPGRADED is showed when a group is in migration.
| Code Block |
|---|
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --members --verbose GROUP CONSUMER-ID HOST CLIENT-ID #PARTITIONS CURRENT-EPOCH CURRENT-ASSIGNMENT TARGET-EPOCH TARGET-ASSIGNMENT IS-CLASSICUPGRADED my-group T4tbGKsvT7CtsxVBH5J2QQ /127.0.0.1 consumer-groupmember 3 43 my_topic:0,1;new_topic:0 3 my_topic:0,1;new_topic:0,1 10 true my-group 6mfoIHq4n3BT7n1HCdqihb /127.0.0.1 classic-member 1 2 - 3 my_topic:0,1;new_topic:0,1 false |
Following table lists IS-CLASSIC UPGRADED meaning.
| IS-CLASSICUPGRADED | Meaning | ||
|---|---|---|---|
| "true" | A consumer member in classic a consumer group. | ||
| "false" | A classic member with non-null classicMemberMetadata in a consumer group. | "false" | Other members. |
--describe --offsets --verbose / --describe --verbose
...
| Code Block |
|---|
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --offsets --verbose GROUP TOPIC PARTITION LEADER-EPOCH CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID my-group my_topic 0 1 10 10 100 T4tbGKsvT7CtsxVBH5J2QQ /127.0.0.1 consumer-groupmember my-group my_topic 1 1 10 10 100 T4tbGKsvT7CtsxVBH5J2QQ /127.0.0.1 consumer-groupmember my-group new_topic 0 1 10 10 100 T4tbGKsvT7CtsxVBH5J2QQ /127.0.0.1 consumer-groupmember my-group new_topic 1 1 100 10 10 T4tbGKsvT7CtsxVBH5J2QQ6mfoIHq4n3BT7n1HCdqihb /127.0.0.1 consumerclassic-groupmember |
kafka-share-groups.sh
Add a new "–verbose" option to ShareGroupCommandOptions.
...