From 31b7ef5d7f7a4aa694e92368a2978cda08a97ebf Mon Sep 17 00:00:00 2001
From: Ning Yu <ningyu@automq.com>
Date: Fri, 10 May 2024 17:18:19 +0800
Subject: [PATCH] chore: switch to dev mode

Signed-off-by: Ning Yu <ningyu@automq.com>
---
 .../log/stream/s3/failover/DefaultFailoverFactory.java      | 5 +++++
 .../log/stream/s3/streams/ControllerStreamManager.java      | 6 ++++++
 gradle/dependencies.gradle                                  | 2 +-
 3 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/core/src/main/scala/kafka/log/stream/s3/failover/DefaultFailoverFactory.java b/core/src/main/scala/kafka/log/stream/s3/failover/DefaultFailoverFactory.java
index 4f442b3054..7593e3df22 100644
--- a/core/src/main/scala/kafka/log/stream/s3/failover/DefaultFailoverFactory.java
+++ b/core/src/main/scala/kafka/log/stream/s3/failover/DefaultFailoverFactory.java
@@ -23,6 +23,7 @@
 import kafka.log.stream.s3.streams.ControllerStreamManager;
 
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 
 public class DefaultFailoverFactory implements FailoverFactory {
@@ -48,6 +49,10 @@ public CompletableFuture<Long> createStream() {
                 return CompletableFuture.failedFuture(new UnsupportedOperationException());
             }
 
+            public CompletableFuture<Long> createStream(Map<String, String> map) {
+                return CompletableFuture.failedFuture(new UnsupportedOperationException());
+            }
+
             public CompletableFuture<StreamMetadata> openStream(long streamId, long epochx) {
                 return CompletableFuture.failedFuture(new UnsupportedOperationException());
             }
diff --git a/core/src/main/scala/kafka/log/stream/s3/streams/ControllerStreamManager.java b/core/src/main/scala/kafka/log/stream/s3/streams/ControllerStreamManager.java
index 120481a1c6..a425d01d35 100644
--- a/core/src/main/scala/kafka/log/stream/s3/streams/ControllerStreamManager.java
+++ b/core/src/main/scala/kafka/log/stream/s3/streams/ControllerStreamManager.java
@@ -52,6 +52,7 @@
 import org.slf4j.LoggerFactory;
 
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
@@ -163,6 +164,11 @@ public Builder toRequestBuilder() {
         return future;
     }
 
+    @Override
+    public CompletableFuture<Long> createStream(Map<String, String> tags) {
+        return createStream();
+    }
+
     @Override
     public CompletableFuture<StreamMetadata> openStream(long streamId, long epoch) {
         OpenStreamRequest request = new OpenStreamRequest()
diff --git a/gradle/dependencies.gradle b/gradle/dependencies.gradle
index 5259c37208..6480e1dc92 100644
--- a/gradle/dependencies.gradle
+++ b/gradle/dependencies.gradle
@@ -250,6 +250,6 @@ extLibs += [
 ]
 branchVersions += [
   s3stream: {
-    require "1.0.5-s3stream"
+    branch = "main"
   }
 ]