как указать брокеров kafka с KafkaIO в Apache Beam

Я пытаюсь настроить конвейер KafkaIO, но не могу понять, как указать брокеров. Указание имени брокера и порта, похоже, этого не делает. Я ни в коем случае не указываю, где находится мой кластер 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 работает локально, и идентификатор брокера правильный.

Что мне не хватает? Как правильно указывать брокеров?

Источник

1 ответ

Turns out it's simply

withBootstrapServers("localhost:9092")
Источник
Другие вопросы по тегам