From d61e6ea243c5917a02eccac788b24f7e17b77b92 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Arnaud=20Cogolu=C3=A8gnes?=
 <514737+acogoluegnes@users.noreply.github.com>
Date: Thu, 27 Mar 2025 17:12:21 +0100
Subject: [PATCH] Remove random and least-leaders leader locator strategy

Deprecated for several releases.
---
 .../com/rabbitmq/stream/StreamCreator.java     | 18 +-----------------
 .../stream/impl/StreamStreamCreator.java       |  2 +-
 2 files changed, 2 insertions(+), 18 deletions(-)

diff --git a/src/main/java/com/rabbitmq/stream/StreamCreator.java b/src/main/java/com/rabbitmq/stream/StreamCreator.java
index c37c04fc2d..659a53e728 100644
--- a/src/main/java/com/rabbitmq/stream/StreamCreator.java
+++ b/src/main/java/com/rabbitmq/stream/StreamCreator.java
@@ -146,23 +146,7 @@ enum LeaderLocator {
      *
      * <p>Default value for RabbitMQ 3.10+.
      */
-    BALANCED("balanced"),
-
-    /**
-     * The stream leader will be a random node of the cluster.
-     *
-     * <p>Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}.
-     */
-    RANDOM("random"),
-
-    /**
-     * The stream leader will be on the node with the least number of stream leaders.
-     *
-     * <p>Deprecated as of RabbitMQ 3.10, same as {@link LeaderLocator#BALANCED}.
-     *
-     * <p>Default value for RabbitMQ 3.9.
-     */
-    LEAST_LEADERS("least-leaders");
+    BALANCED("balanced");
 
     String value;
 
diff --git a/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java b/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java
index 86e3693ad7..c3d216046e 100644
--- a/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java
+++ b/src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java
@@ -32,7 +32,7 @@ class StreamStreamCreator implements StreamCreator {
 
   private final StreamEnvironment environment;
   private final Client.StreamParametersBuilder streamParametersBuilder =
-      new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.LEAST_LEADERS);
+      new Client.StreamParametersBuilder().leaderLocator(LeaderLocator.BALANCED);
   private String name;
   private DefaultSuperStreamConfiguration superStreamConfiguration;