There currently isn't one in Python but there is one in Java. Consider contributing a cross-lang connector to MQTT. There are several other dev threads about doing this for other IOs and examples you can look at like Kafka.
On Thu, Aug 6, 2020 at 9:43 AM Zeolla, Nicholas, Vodafone Group < [email protected]> wrote: > Hi all, > > > > I’m looking to use MQTT as the messaging broker in my streaming python > pipeline – is there any current efforts with this currently happening? > Would be very interested in knowing this before I attempt a custom io > connector <https://beam.apache.org/documentation/io/developing-io-python/>. > > > > > Thanks, > > Nick > > > > [image: Vodafone] <http://vodafone.com/> > > *Nicholas Zeolla* > Technology Discover Graduate > Analytics Centre of Excellence > +44 7876875333 <+44%207876%20875333> > *[email protected] <[email protected]>* > > > Newbury Office > > > vodafone.com > > > *The future is exciting.* > *Ready?* > > [image: > https://oitcolpdoprodsa.blob.core.windows.net/signaturetool/Group300x80.jpg] > > > > Vodafone Group Services Limited Registered Office: Vodafone House, The > Connection, Newbury, Berkshire RG14 2FN. Registered in England number > 3802001 > > > > > > C2 General >
