Extend configuration options of MQTT adapter

[dominikriemer]

Body

Add more configuration options to the MQTT adapter:

• TLS encryption
• Authentication
• other configuration options as already present in the MQTT sink

Also, add better exception handling to the adapter similar to OPC-UA so that users get better error messages in case the connection is invalid.

StreamPipes Committer

I acknowledge that I am a maintainer/committer of the Apache StreamPipes project.

[shashwatik]

Hi dominikriemer, I want to contribute to this issue, could you please let me know how I can get involved and what the next steps would be?

[bossenti]

Hi @shashwatik,

great to hear that you are interested in contributing here 🤩
I can assign the issue to you, if you want.

I think the first step for you would be to get the development environment for StreamPipes ready and get a basic understanding for StreamPipes.
Here are some supporting links:

• https://cwiki.apache.org/confluence/display/STREAMPIPES/Extensions
• https://streampipes.apache.org/docs/docs/extend-tutorial-data-sources.html
• https://streampipes.apache.org/docs/docs/extend-tutorial-data-processors.html
• https://streampipes.apache.org/docs/docs/extend-tutorial-data-sinks.html

Once you are ready, you can actually start to work on this issue.
Like stated in the description, it is about adding some more advanced configuration settings to the MQTT adapter.
Some of the listed ones are already implemented for the MQTT sink, so you can have a look there as well.

Ideally, you could event extend then the E2E tests for MQTT and include the improvements you introduce while working on this (see #1489).

Hope this answers your questions, makes you ready to start and does not overwhelm you 🙂
If you are only willing to contribute a fraction of it, this helps us already a lot!

[shashwatik]

Hi @bossenti could you help me in setting up the codebase?

[tenthe]

Hi @shashwatik,
here is a link with the description to setup your development environment.

https://cwiki.apache.org/confluence/display/STREAMPIPES/Extensions

Please let us know if you have any questions

[tenthe]

Hi @shashwatik,
here is a link with the description to setup your development environment.

https://cwiki.apache.org/confluence/display/STREAMPIPES/Extensions

Please let us know if you have any questions