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

apache / beam

Apache Beam is a unified programming model for Batch and Streaming data processing.

https://beam.apache.org/

Apache License 2.0

7.81k stars 4.23k forks source link

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

Open SamLeurink opened 3 weeks ago

SamLeurink commented 3 weeks ago

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
[X] Component: Java SDK
[ ] Component: Go SDK
[ ] Component: Typescript SDK
[X] 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 commented 2 days ago

.take-issue

twosom commented 2 days ago

I think this feature is related to #32195