yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #9866 from sstrigler/EMQX-8812-inconsistent-metrics-for-bridge-in-async-mode 

fix: increase dropped.queue_full by number of messages
This commit is contained in:
Zaiming (Stone) Shi 2023-01-30 14:14:47 +01:00 committed by GitHub
parent dc82de0eda 27881064dc
commit 74b8795d01
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx_resource/src/emqx_resource_buffer_worker.erl
View File

@ -1094,7 +1094,7 @@ append_queue(Id, Index, Q, Queries) ->
{Q1, QAckRef, Items2} = replayq:pop(Q0, PopOpts), {Q1, QAckRef, Items2} = replayq:pop(Q0, PopOpts),
ok = replayq:ack(Q1, QAckRef), ok = replayq:ack(Q1, QAckRef),
Dropped = length(Items2), Dropped = length(Items2),
emqx_resource_metrics:dropped_queue_full_inc(Id), emqx_resource_metrics:dropped_queue_full_inc(Id, Dropped),
?SLOG(info, #{ ?SLOG(info, #{
msg => buffer_worker_overflow, msg => buffer_worker_overflow,
worker_id => Id, worker_id => Id,