requirements

Author: ovv

conda/post-link.sh

@@ -5,4 +5,5 @@ $PREFIX/bin/pip install \
 'protobuf>=5.27.2,<6.0' \
 'influxdb3-python>=0.7,<1.0' \
 'pyiceberg[pyarrow,glue]>=0.7,<0.8' \
-'redis[hiredis]>=5.2.0,<6'
+'redis[hiredis]>=5.2.0,<6' \
+'paho-mqtt>=2.1.0,<3'

pyproject.toml

@@ -38,7 +38,7 @@ all = [
     "boto3>=1.35.65,<2.0",
     "boto3-stubs>=1.35.65,<2.0",
     "redis[hiredis]>=5.2.0,<6",
-    "paho-mqtt==2.1.0"
+    "paho-mqtt>=2.1.0,<3"
 ]
 
 avro = ["fastavro>=1.8,<2.0"]
@@ -51,6 +51,7 @@ pubsub = ["google-cloud-pubsub>=2.23.1,<3"]
 postgresql = ["psycopg2-binary>=2.9.9,<3"]
 kinesis = ["boto3>=1.35.65,<2.0", "boto3-stubs[kinesis]>=1.35.65,<2.0"]
 redis=["redis[hiredis]>=5.2.0,<6"]
+mqtt=["paho-mqtt>=2.1.0,<3"]
 
 [tool.setuptools.packages.find]
 include = ["quixstreams*"]

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