You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@beam.apache.org by Carolyn Langen <ca...@almende.org> on 2020/09/28 07:32:29 UTC

How to write a Python wrapper for MQTT io

Greetings,

I need Python MQTT IO support for a project I'm working on. I've looked at
the Kafka IO module, and planned to follow it, but I'm having trouble
finding the URN to use, and how to configure the input parameters. Is there
any documentation about this? If not, I'd appreciate an explanation of the
steps I need to take to implement this.

Best regards,
Carolyn