我试图建立一个Kafka约管道，但我不知道如何指定经纪人。指定的brokername和port似乎不起作用。我从未指定我的Kafka集群在哪里：

pipeline
            .apply(KafkaIO.<Long, String>read()
                    .withBootstrapServers("broker.id__1:9092")
                    .withTopic("pageviews")

这给了我一个错误：

Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
        at org.apache.beam.sdk.Pipeline.run(Pipeline.java:323)
...
    Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers

我的kafka集群正在本地运行，代理id是正确的。
我错过了什么？指定经纪人的正确方法是什么？