def can_send_more(self):
        """Check for throttling / quota violations and max in-flight-requests"""
        if self.throttle_delay() > 0:
            return False
        max_ifrs = self.config['max_in_flight_requests_per_connection']
        return len(self.in_flight_requests) < max_ifrs
Check for throttling / quota violations and max in-flight-requests
kafka/conn.py