chore(bridges): increase log level for bridge buffer overflow reports

Co-authored-by: Andrew Mayorov <encube.ul@gmail.com>
This commit is contained in:
Ilya Averyanov 2024-05-28 12:47:04 +03:00
parent 238c207b09
commit db713cb656
4 changed files with 6 additions and 4 deletions

View File

@ -85,7 +85,8 @@
cannot_publish_to_topic_due_to_quota_exceeded, cannot_publish_to_topic_due_to_quota_exceeded,
connection_rejected_due_to_license_limit_reached, connection_rejected_due_to_license_limit_reached,
dropped_msg_due_to_mqueue_is_full, dropped_msg_due_to_mqueue_is_full,
socket_receive_paused_by_rate_limit socket_receive_paused_by_rate_limit,
data_bridge_buffer_overflow
]). ]).
%% Callback to upgrade config after loaded from config file but before validation. %% Callback to upgrade config after loaded from config file but before validation.

View File

@ -1,7 +1,7 @@
%% -*- mode: erlang -*- %% -*- mode: erlang -*-
{application, emqx_resource, [ {application, emqx_resource, [
{description, "Manager for all external resources"}, {description, "Manager for all external resources"},
{vsn, "0.1.29"}, {vsn, "0.1.30"},
{registered, []}, {registered, []},
{mod, {emqx_resource_app, []}}, {mod, {emqx_resource_app, []}},
{applications, [ {applications, [

View File

@ -1777,8 +1777,8 @@ append_queue(Id, Index, Q, Queries) ->
ok = replayq:ack(Q1, QAckRef), ok = replayq:ack(Q1, QAckRef),
Dropped = length(Items2), Dropped = length(Items2),
Counters = #{dropped_queue_full => Dropped}, Counters = #{dropped_queue_full => Dropped},
?SLOG(info, #{ ?SLOG_THROTTLE(warning, #{
msg => "buffer_worker_overflow", msg => data_bridge_buffer_overflow,
resource_id => Id, resource_id => Id,
worker_index => Index, worker_index => Index,
dropped => Dropped dropped => Dropped

View File

@ -0,0 +1 @@
Emit a `warning` level throttled log when bridge buffers are overflown and messages get dropped. Previously, the log events had `info` level and were not visible with the default log level.