docs: def _get_conn(self, host, port):
          """Get or create a connection to a broker using host and port"""
          host_key = (host, port)
          if host_key not in self.conns:
              self.conns[host_key] = KafkaConnection(
                  host,
                  port,
                  timeout=self.timeout
              )
  
          return self.conns[host_key]