diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl
index ec594c51f989..6ab5f0d4501f 100644
--- a/deps/rabbit/src/rabbit_stream_queue.erl
+++ b/deps/rabbit/src/rabbit_stream_queue.erl
@@ -328,7 +328,7 @@ consume(Q, Spec, #stream_client{} = QState0)
                     AckRequired = not NoAck,
                     rabbit_core_metrics:consumer_created(
                       ChPid, ConsumerTag, ExclusiveConsume, AckRequired,
-                      QName, ConsumerPrefetchCount, false, up, Args),
+                      QName, ConsumerPrefetchCount, true, up, Args),
                     %% reply needs to be sent before the stream
                     %% begins sending
                     maybe_send_reply(ChPid, OkMsg),