diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-10-22 09:07:23 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-12-21 11:39:25 -0800 |
| commit | 3432a0bf5285cbd1d75bfc7728d2ab56aa748d42 (patch) | |
| tree | 4f26d16b471cf96ff8382fa6a4252977e89554d4 | |
| parent | 4209b881a22fbcf6453e01037c0596c7da21091b (diff) | |
| download | kafka-python-3432a0bf5285cbd1d75bfc7728d2ab56aa748d42.tar.gz | |
coordinator.poll should not use join group with 0.8.2 brokers
| -rw-r--r-- | kafka/coordinator/consumer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/coordinator/consumer.py b/kafka/coordinator/consumer.py index 9e680c1..2bfdffa 100644 --- a/kafka/coordinator/consumer.py +++ b/kafka/coordinator/consumer.py @@ -244,7 +244,7 @@ class ConsumerCoordinator(BaseCoordinator): self._invoke_completed_offset_commit_callbacks() self.ensure_coordinator_ready() - if self._subscription.partitions_auto_assigned(): + if self.config['api_version'] >= (0, 9) and self._subscription.partitions_auto_assigned(): if self.need_rejoin(): # due to a race condition between the initial metadata fetch and the # initial rebalance, we need to ensure that the metadata is fresh |