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

fix: increase dropped.queue_full by number of messages

This commit is contained in:
Stefan Strigler 2023-01-30 11:34:04 +01:00
parent dc82de0eda
commit 27881064dc
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,