Skip to content

Commit fee80a1

Browse files
committed
Do not emit consumer lag for inactive consumer
References #3753
1 parent 22db5ed commit fee80a1

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

deps/rabbitmq_stream/src/rabbit_stream_reader.erl

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3204,6 +3204,8 @@ consumer_i(offset,
32043204
#consumer{configuration =
32053205
#consumer_configuration{counters = Counters}}) ->
32063206
consumer_offset(Counters);
3207+
consumer_i(offset_lag, #consumer{log = undefined}) ->
3208+
0;
32073209
consumer_i(offset_lag,
32083210
#consumer{configuration =
32093211
#consumer_configuration{counters = Counters},

0 commit comments

Comments
 (0)