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]

Reply via email to