From 176623aff333e3b8d19649b0bc305bd85997d385 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?= <acogoluegnes@tuta.io>
Date: Wed, 29 Jan 2025 11:18:19 +0100
Subject: [PATCH] Use local read to check node is in maintenance

In stream reader. The consistent read may cause some timeout for the
metadata frame.
---
 deps/rabbitmq_stream/src/rabbit_stream_reader.erl | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl
index 02233757103c..b37ae339f4a5 100644
--- a/deps/rabbitmq_stream/src/rabbit_stream_reader.erl
+++ b/deps/rabbitmq_stream/src/rabbit_stream_reader.erl
@@ -2417,12 +2417,10 @@ handle_frame_post_auth(Transport,
         lists:sort(
             maps:keys(NodesMap)),
     %% filter out nodes in maintenance
-    Nodes =
-        lists:filter(fun(N) ->
-                        rabbit_maintenance:is_being_drained_consistent_read(N)
-                        =:= false
-                     end,
-                     Nodes0),
+        Nodes = lists:filter(fun(N) ->
+                                     rabbit_maintenance:is_being_drained_local_read(N) =:= false
+                             end,
+                             Nodes0),
     NodeEndpoints =
         lists:foldr(fun(Node, Acc) ->
                        PortFunction =