MQTT

Subscribes to an MQTT topic and ingests messages.

Configuration

yaml

source:
  kind: mqtt
  broker_url: "mqtt.example.com"
  port: 1883
  topic: "sensors/temperature"

Field	Default	Description
`broker_url`	(required)	MQTT broker hostname
`port`	`1883`	Broker port
`topic`	(required)	Topic to subscribe to
`client_id`	auto-generated	MQTT client ID
`qos`	`1`	Quality of Service (0, 1, 2)
`username` / `password`		Optional broker credentials
`mode`	`stream`	`stream` or `batch`
`idle_timeout_seconds`	`5`	Batch mode idle timeout

Namespace: mqtt.{topic}

bash

skippr connect source mqtt \
  --broker-url mqtt://broker.example.com \
  --topic sensors/temperature