Repository navigation

feat(connectors): add MQTT sink connector - #4584

Open

ygndotgg wants to merge 16 commits into

apache:masterfrom

ygndotgg:feat/connectors-mqtt-sinkk

Open

feat(connectors): add MQTT sink connector#4584
ygndotgg wants to merge 16 commits into
apache:masterfrom
ygndotgg:feat/connectors-mqtt-sinkk

Commits on Oct 26, 2026
- feat(connectors): Initial MQTT Sink Connector
  ygndotgg
  committed
  046a6af
- feat(connectors): add bounded MQTT pipelining
  ygndotgg
  committed
  ea315dd
- feat(connectors): harden MQTT sink reconnect and shutdown draining
  ygndotgg
  committed
  f42fcb5
- feat(connectors): classify MQTT sink errors by retryability
  ygndotgg
  committed
  edb4128
- feat(connectors): validate MQTT sink topics, properties, and broker URLs
  ygndotgg
  committed
  3ea677b
- feat(connectors): add TLS transport and error handling
  ygndotgg
  committed
  f2fd108
- feat(connectors): harden MQTT sink delivery
  ygndotgg
  committed
  e36a0f9
- fix(connectors): harden MQTT sink publishing
  ygndotgg
  committed
  a1df67e
- fix(connectors): simplify MQTT sink publish path
  ygndotgg
  committed
  c686c48
- docs(connectors): clarify MQTT sink configuration and delivery behavior
  ygndotgg
  committed
  8303e4b
- fix(connectors): harden MQTT sink delivery and validation
  ygndotgg
  committed
  297b370
- test(connectors): improve MQTT sink integration coverage
  ygndotgg
  committed
  e796a18
- docs(connectors): update MQTT sink configuration
  ygndotgg
  committed
  53aeba4
- fix(connectors): Harden MQTT sink recovery and integration coverage
  ygndotgg
  committed
  0943e3f
- fix(connectors): adapt MQTT sink to split rumqttc crates
  ygndotgg
  committed
  94671fc
- fix(connectors): retry MQTT publications with fresh deadlines
  ygndotgg
  committed
  3af7263