summaryrefslogtreecommitdiff
path: root/kafka/errors.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 08:40:38 -0800
commit2ba5f07b7154fde9523086142b755a2d6d450dba (patch)
tree34bb8931df7b2b6ca334f9593a6f77f77295d857 /kafka/errors.py
parent269938bd89e5162f57e0cec80c443af37158a240 (diff)
downloadkafka-python-fix-describe-groups.tar.gz
Fix describe_groupsfix-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/errors.py')
0 files changed, 0 insertions, 0 deletions