25b0e31035
Fixes https://emqx.atlassian.net/browse/EMQX-10279 Related: https://github.com/emqx/emqx/pull/11038 Since wolff client has its own replayq that lives outside the management of the buffer workers, we must not return disconnected status for such bridge: otherwise, the resource manager will eventually kill the producers and data may be lost.
132 B
132 B
Fixed a health check issue for Kafka Producer that could lead to loss of messages when the connection to Kafka's brokers were down.