[Feature Request]: Topic array support for MqttIO.Read

[SamLeurink]

What would you like to happen?

Currently MqttIO.ConnectionConfiguration only allows for a singular topic which in turn means that MqttIO.Read can only be done on one topic.

The use of topic arrays would, for me at least, greatly improve flexibility.

Issue Priority

Priority: 2 (default / most feature requests should be filed as P2)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam YAML
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Infrastructure
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[twosom]

.take-issue

[twosom]

I think this feature is related to #32195

[twosom]

@SamLeurink
Hi,

I’ve added support for subscribing to multiple topics in MqttIO.read and MqttIO.readWithMetadata #32881.
Now you can configure multiple topics like this:

pipeline.apply(
    MqttIO.readWithMetadata()
        .withConnectionConfiguration(
            MqttIO.ConnectionConfiguration.create(
                "tcp://host:1883",
                "topic1",
                "topic2",
                "topic3"))
);

Let me know if you have any feedback!