A partial backport of #8358

Author: michaelklishin

deps/rabbit/priv/schema/rabbit.schema

@@ -2783,6 +2783,12 @@ end}.
     {datatype, [binary]}
 ]}.
 
+
+%% See github.com/rabbitmq/osiris#192 and https://github.com/rabbitmq/rabbitmq-server/commit/9f162dfd01c1516d168e7d1fad39d33a929756e5
+%% Enables read-head
+{mapping, "stream.read_ahead", "rabbit.stream_read_ahead",
+    [{datatype, {enum, [true, false]}}]}.
+
 {translation, "rabbit.cluster_tags",
 fun(Conf) ->
     case cuttlefish:conf_get("cluster_tags", Conf, undefined) of

deps/rabbit/src/rabbit_stream_queue.erl

@@ -11,7 +11,6 @@
 -include("mc.hrl").
 
 -behaviour(rabbit_queue_type).
--behaviour(rabbit_queue_commands).
 
 -export([is_enabled/0,
          is_compatible/3,
@@ -1555,3 +1554,6 @@ reclaim_memory(_QName) ->
 
 shrink_all(_Node) ->
     {error, not_quorum_queue}.
+
+read_ahead_on() ->
+    application:get_env(rabbit, stream_read_ahead, true).

deps/rabbit/test/config_schema_SUITE_data/rabbit.snippets

@@ -1224,6 +1224,27 @@ credential_validator.regexp = ^abc\\d+",
      ]}],
    []},
 
+  %%
+  %% Stream read ahead on/off
+  %%
+
+  {stream_read_ahead,
+   "
+    stream.read_ahead = true
+   ",
+   [{rabbit, [
+      {stream_read_ahead, true}
+     ]}],
+   []},
+
+  {stream_read_ahead,
+   "
+    stream.read_ahead = false
+   ",
+   [{rabbit, [
+      {stream_read_ahead, false}
+     ]}],
+
   {stream_replication_port_range,
    "
     stream.replication.port_range.max = 4600