summaryrefslogtreecommitdiff
path: root/kafka/protocol/admin.py
diff options
context:
space:
mode:
authorJeff Widman <jeff@jeffwidman.com>2018-11-17 02:46:18 -0800
committerJeff Widman <jeff@jeffwidman.com>2018-11-18 15:37:36 -0800
commit8dab14b6d73d8f1717fdeb46c79807827169fd2d (patch)
tree6a213de46b204ef841be999d1b698e0be4f955d2 /kafka/protocol/admin.py
parent665f1e4dc4f809e4b70af71b1995d2fe6ed12a45 (diff)
downloadkafka-python-8dab14b6d73d8f1717fdeb46c79807827169fd2d.tar.gz
Fix describe_groups
This was completely broken previously because it didn't lookup the group coordinator of the consumer group. Also added basic error handling/raising. Note: I added the `group_coordinator_id` as an optional kwarg. As best I can tell, the Java client doesn't include this and instead looks it up every time. However, if we add this, it allows the caller the flexibility to bypass the network round trip of the lookup if for some reason they already know the `group_coordinator_id`.
Diffstat (limited to 'kafka/protocol/admin.py')
0 files changed, 0 insertions, 0 deletions