Searched defs:_on_join_complete (Results 1 – 2 of 2) sorted by relevance
| /dports/net/py-kafka-python/kafka-python-1.4.5/kafka/coordinator/ | ||
| H A D | consumer.py | 212 def _on_join_complete(self, generation, member_id, protocol, member in ConsumerCoordinator |
| H A D | base.py | 205 def _on_join_complete(self, generation, member_id, protocol, member in BaseCoordinator |