async def METHOD_NAME(docker_client: DockerClient, zookeeper: str, kafka_network: str) -> str:
    [kafka_port] = get_available_ports()
    container = docker_client.containers.run(
        name="kafka",
        image="confluentinc/cp-kafka:latest",
        ports={
            f"{kafka_port}/tcp": str(kafka_port),
        },
        environment={
            "KAFKA_ZOOKEEPER_CONNECT": zookeeper,
            "KAFKA_ADVERTISED_LISTENERS": (
                f"PLAINTEXT://kafka:9092,PLAINTEXT_HOST://localhost:{kafka_port}"
            ),
            "KAFKA_LISTENER_SECURITY_PROTOCOL_MAP": (
                "PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT"
            ),
            "KAFKA_INTER_BROKER_LISTENER_NAME": "PLAINTEXT",
        },
        network=kafka_network,
        detach=True,
    )
    kafka_server = f"localhost:{kafka_port}"
    try:
        # Wait until Kafka server is healthy
        await bootstrap(kafka_server)
        yield kafka_server
    except Exception:
        raise
    finally:
        # Ensure we always remove the container
        container.remove(force=True)