diff options
| -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}, |