(self, group)
Determine which broker is the Group Coordinator for a specific consumer group.
Determine which broker is the Group Coordinator for a specific consumer group.
Determine which broker is the Group Coordinator for a specific consumer group .
def _get_group_coordinator(self, group):
        """Determine which broker is the Group Coordinator for a specific consumer group."""
        request = GroupCoordinatorRequest[0](group)
        response = self._make_blocking_req(request)
        error_type = kafka_errors.for_code(response.error_code)
        if error_type is kafka_errors.NoError:
            return response.coordinator_id
def _get_group_coordinator ( self , group ) : request = GroupCoordinatorRequest [ 0 ] ( group ) response = self . _make_blocking_req ( request ) error_type = kafka_errors . for_code ( response . error_code ) if error_type is kafka_errors . NoError : return response . coordinator_id