enhancement(mqtt source): support end-to-end acknowledgements#25785

Open

antaresindustries wants to merge 9 commits into

vectordotdev:masterfrom

antaresindustries:mqtt-source-e2e-acknowledgements

Commits on Jul 14, 2026

enhancement(mqtt source): support end-to-end acknowledgements
antaresindustries
committed
add more tests to all possible state transitions
antaresindustries
committed
fix(mqtt source): send PUBACKs in the order publishes were received
antaresindustries
committed
fix(mqtt source): withhold later acks after a failure, recreate finalizer on reconnect
antaresindustries
committed
fix(mqtt source): drop stale acks, confirm resubscribes via SUBACK, reconnect on withheld ack
antaresindustries
committed
fix(mqtt source): harden reconnect/ack state machine against liveness holes and cross-layer staleness
antaresindustries
committed
fix(mqtt source): keep auto-acked buffered publishes on disconnect, reject invalid topic filters at build
antaresindustries
committed
test(mqtt source): exhaustively model-check the protocol state machine, fault-inject against a live broker
antaresindustries
committed

Commits on Jul 15, 2026

fix(mqtt source): keep buffered QoS 0 publishes across disconnects in ack mode
antaresindustries
committed