code: def test_send_no_response(_socket, conn):
      conn.connect()
      assert conn.state is ConnectionStates.CONNECTED
      req = ProduceRequest[0](required_acks=0, timeout=0, topics=())
      header = RequestHeader(req, client_id=conn.config["client_id"])
      payload_bytes = len(header.encode()) + len(req.encode())
      third = payload_bytes // 3
      remainder = payload_bytes % 3
      _socket.send.side_effect = [4, third, third, third, remainder]
  
      assert len(conn.in_flight_requests) == 0
      f = conn.send(req)
      assert f.succeeded() is True
      assert f.value is None
      assert len(conn.in_flight_requests) == 0
  
imports: from __future__ import absolute_import
  from errno import EALREADY, EINPROGRESS, EISCONN, ECONNRESET
  import socket
  import mock
  import pytest
  from kafka.conn import BrokerConnection, ConnectionStates, collect_hosts
  from kafka.protocol.api import RequestHeader
  from kafka.protocol.metadata import MetadataRequest
  from kafka.protocol.produce import ProduceRequest
  import kafka.errors
label_desc: Use image node_id 13 for calling a global function with example usage: test_send_no_response(_socket, conn) without return types