requirements

Author: ovv

conda/post-link.sh

@@ -8,4 +8,5 @@ $PREFIX/bin/pip install \
 'redis[hiredis]>=5.2.0,<6' \
 'confluent-kafka[avro,json,protobuf,schemaregistry]>=2.8.2,<2.10' \
 'influxdb>=5.3,<6' \
-'jsonpath_ng>=1.7.0,<2'
+'jsonpath_ng>=1.7.0,<2' \
+'paho-mqtt>=2.1.0,<3'

pyproject.toml

@@ -44,7 +44,7 @@ all = [
     "pandas>=1.0.0,<3.0",
     "elasticsearch>=8.17,<9",
     "influxdb>=5.3,<6",
-    "paho-mqtt==2.1.0"
+    "paho-mqtt>=2.1.0,<3"
 ]
 
 avro = ["fastavro>=1.8,<2.0"]
@@ -62,6 +62,7 @@ neo4j = ["neo4j>=5.27.0,<6"]
 mongodb = ["pymongo>=4.11,<5"]
 pandas = ["pandas>=1.0.0,<3.0"]
 elasticsearch = ["elasticsearch>=8.17,<9"]
+mqtt = ["paho-mqtt>=2.1.0,<3"]
 
 # AWS dependencies are separated by service to support
 # different requirements in the future.

quixstreams/sinks/community/mqtt.py

@@ -10,8 +10,7 @@
     from paho import mqtt
 except ImportError as exc:
     raise ImportError(
-        'Package "paho-mqtt" is missing: '
-        "run pip install quixstreams[paho-mqtt] to fix it"
+        'Package "paho-mqtt" is missing: ' "run pip install quixstreams[mqtt] to fix it"
     ) from exc