Use client-local for default leader locator strategy

References rabbitmq/rabbitmq-server#4442.

Fixes #110

Author: acogoluegnes

src/main/java/com/rabbitmq/stream/StreamCreator.java

@@ -67,13 +67,34 @@ public interface StreamCreator {
 
   /** The leader locator strategy. */
   enum LeaderLocator {
-    /** The stream leader will be on the node the client is connected to. */
+
+    /**
+     * The stream leader will be on the node the client is connected to.
+     *
+     * <p>This is the default value.
+     */
     CLIENT_LOCAL("client-local"),
 
-    /** The stream leader will be a random node of the cluster. */
+    /**
+     * The leader will be the node hosting the minimum number of stream leaders, if there are
+     * overall less than 1000 queues, or a random node, if there are overall more than 1000 queues.
+     *
+     * <p>Available as of 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. */
+    /**
+     * 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}.
+     */
     LEAST_LEADERS("least-leaders");
 
     String value;

src/main/java/com/rabbitmq/stream/impl/StreamStreamCreator.java

@@ -25,7 +25,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.CLIENT_LOCAL);
   private String stream;
 
   StreamStreamCreator(StreamEnvironment environment) {

src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

@@ -239,9 +239,9 @@ public class StreamPerfTest implements Callable<Integer> {
       names = {"--leader-locator", "-ll"},
       description =
           "leader locator strategy for created stream. "
-              + "Possible values: client-local, least-leaders, random.",
+              + "Possible values: client-local, balanced (RabbitMQ 3.10), least-leaders, random.",
       converter = Utils.LeaderLocatorTypeConverter.class,
-      defaultValue = "least-leaders")
+      defaultValue = "client-local")
   private LeaderLocator leaderLocator;
 
   @CommandLine.Option(