Got error when running case `mqtt::sink::test::test_mqtt` in CI

[zhuliquan]

I often encounter the following errors when running CI

--- STDOUT:              arroyo-connectors mqtt::sink::test::test_mqtt ---

running 1 test
test mqtt::sink::test::test_mqtt ... FAILED

failures:

failures:
    mqtt::sink::test::test_mqtt

test result: FAILED. 0 passed; 1 failed; 0 ignored; 0 measured; 7 filtered out; finished in 0.07s

--- STDERR:              arroyo-connectors mqtt::sink::test::test_mqtt ---
thread 'mqtt::sink::test::test_mqtt' panicked at crates/arroyo-connectors/src/mqtt/sink/test.rs:172:17:
Error in mqtt event loop: MqttState(Io(Custom { kind: ConnectionAborted, error: "connection closed by peer" }))
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace

[mwylde]

Yes, unfortunately this test is flakey in CI. It would be great to spend some time trying to figure out why (it seems to run reliably locally).

[zhuliquan]

It may be due to an unreliable CI environment