def METHOD_NAME(
    key: KEY_TYPE, connection_timeout=DEFAULT_CONNECTION_TIMEOUT
) -> BaseBuffer:
    if not settings.OBSERVABILITY_BROKER_URL:
        raise ConnectionNotConfigured("The observability broker url not set")
    broker_url = settings.OBSERVABILITY_BROKER_URL
    max_size = settings.OBSERVABILITY_BUFFER_SIZE_LIMIT
    batch_size = settings.OBSERVABILITY_BUFFER_BATCH_SIZE
    timeout = int(settings.OBSERVABILITY_BUFFER_TIMEOUT.total_seconds())
    return RedisBuffer(
        broker_url,
        key,
        max_size,
        batch_size,
        connection_timeout=connection_timeout,
        timeout=timeout,
    )