def METHOD_NAME(self):
    """Creates new connection for consumer."""
    try:
        endpoint_url = urllib.parse.urlparse(
            self._config.get_cortx_s3_endpoint_for_consumer()).netloc
    except KeyError as ex:
        self._logger.error(str(ex))
        return None
    return http.client.HTTPConnection(endpoint_url)