yuanbiao/emqx - emqx

Commit Graph

Author	SHA1	Message	Date
Thales Macedo Garitezi	79cf0a2ced	fix(kafka_producer): correctly handle metrics for connector that have internal buffers Fixes https://emqx.atlassian.net/browse/EMQX-11086 There’s currently a metric inconsistency due to the internal buffering nature of Kafka Producer (wolff). We use simple_sync_query to call the Kafka Producer bridge. If that times out, the call is accounted as failed, even though the message is buffered in wolff and later sent successfully.	2023-10-09 15:02:25 -03:00

Author

SHA1

Message

Date

Thales Macedo Garitezi

79cf0a2ced

fix(kafka_producer): correctly handle metrics for connector that have internal buffers

Fixes https://emqx.atlassian.net/browse/EMQX-11086

There’s currently a metric inconsistency due to the internal buffering nature of Kafka
Producer (wolff).

We use simple_sync_query to call the Kafka Producer bridge.  If that times out, the call
is accounted as failed, even though the message is buffered in wolff and later sent
successfully.

2023-10-09 15:02:25 -03:00

1 Commits