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"
   }
 ]