Luishfs opened a new issue, #3385: URL: https://github.com/apache/iggy/issues/3385
### Description In order to get iggy connectors on a broader range of devices, i'm proposing to implement the MQTT protocol for both sources & sinks. ### Affected area / component Connectors ### Proposed solution I've did some research on Rust crates for the MQTT protocol, and the most reliable ( along with continuous maintenance ) seems to be [flowsdk](https://github.com/emqx/flowsdk/tree/main). I've made a sink MVP with the sink target being a rabbitmq MQTT endpoint (with mqtt 5) and it works as expected: <img width="1764" height="1071" alt="Image" src="https://github.com/user-attachments/assets/f5a54ecd-bc79-470f-a40a-14d74d3cf7c3" /> <img width="1369" height="838" alt="Image" src="https://github.com/user-attachments/assets/8e4810ed-4fb5-4f07-93f4-84b456a733ea" /> So the idea would be: - Implement both Sink and Source with MQTT 5 - Allow for MQTT 3 after MQTT 5 is valid ( the sdk allow for both ) ### Alternatives considered _No response_ ### Contribution - [x] I'm willing to submit a pull request to implement this feature ### Good first issue - [ ] I think this could be a good first issue for a new contributor -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
