MQTT Kafka connector Build local image docker build --no-cache -t piklema/mqtt-kafka-connector:latest . How to run Rename .env.example to .env and changes values Run unittest $ pip install -e ".[develop]" $ make test Run script $ mqtt_kafka_connector