mirror of https://github.com/apache/kafka.git
70c0aca4b7
CI / build (push) Waiting to run
Details
Admin.listConsumerGroups() was able to use the early versions of ListGroups RPC with the version used dependent upon the filters the user specified. Admin.listGroups(ListGroupsOptions.forConsumerGroups()) inadvertently required ListGroups v5 because it always set a types filter. This patch handles the UnsupportedVersionException and winds back the complexity of the request unless the user has specified filters which demand a higher version. It also adds ListGroupsOptions.forShareGroups() and forStreamsGroups(). The usability of Admin.listGroups() is much improved as a result. Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, PoAn Yang <payang@apache.org> |
||
|---|---|---|
| .. | ||
| src | ||
| .gitignore | ||