MQTT: Adding support for MQTT v5

lensesio / stream-reactor

A collection of open source Apache 2.0 Kafka Connector maintained by Lenses.io.

https://lenses.io

Apache License 2.0

1k stars 362 forks source link

MQTT: Adding support for MQTT v5 #793

Open glitchcube opened 3 years ago

glitchcube commented 3 years ago

Hi,

I have noticed that the MQTT Source/Sink connector uses v3 of the eclipse mqtt client library. Is there any plan of updating this to version 5? There are multiple handy features that we would like to you.

I can see here that we are using version 3 https://github.com/lensesio/stream-reactor/blob/master/kafka-connect-mqtt/build.gradle compile "org.eclipse.paho:org.eclipse.paho.client.mqttv3:$mqttVersion"

stheppi commented 3 years ago

@glitchcube yes we want to upgrade. We welcome PRs. Is that something you would be interested to do?