diff options
| author | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-01-20 17:30:56 +0100 |
|---|---|---|
| committer | Arnaud Cogoluègnes <acogoluegnes@gmail.com> | 2022-01-20 18:01:42 +0100 |
| commit | fee80a1146fc659780ba9e225e7b0a842583f1a1 (patch) | |
| tree | 9b8244ee15831de21c8b87aedd6fa3f655789521 | |
| parent | 22db5ed9664ba96572f4fe1b0a7f9f5adb156e0d (diff) | |
| download | rabbitmq-server-git-stream-single-active-consumer.tar.gz | |
Do not emit consumer lag for inactive consumerstream-single-active-consumer
References #3753
| -rw-r--r-- | deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl index 2ffd718517..125dc01d95 100644 --- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl +++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl @@ -3204,6 +3204,8 @@ consumer_i(offset, #consumer{configuration = #consumer_configuration{counters = Counters}}) -> consumer_offset(Counters); +consumer_i(offset_lag, #consumer{log = undefined}) -> + 0; consumer_i(offset_lag, #consumer{configuration = #consumer_configuration{counters = Counters}, |