async def METHOD_NAME(
    cls: Type[EB],
    broker_config: EndpointConfig,
    event_loop: Optional[AbstractEventLoop] = None,
) -> Optional[EB]:
    """Creates an `EventBroker` from the endpoint configuration.
    Args:
        broker_config: The configuration for the broker.
        event_loop: The current event loop or `None`.
    Returns:
        An `EventBroker` object.
    """
    raise NotImplementedError(
        "Event broker must implement the `from_endpoint_config` method."
    )