diff --git a/tools/src/main/java/org/apache/kafka/tools/automq/GenerateS3UrlCmd.java b/tools/src/main/java/org/apache/kafka/tools/automq/GenerateS3UrlCmd.java index a37a8982ee..0f307e7640 100644 --- a/tools/src/main/java/org/apache/kafka/tools/automq/GenerateS3UrlCmd.java +++ b/tools/src/main/java/org/apache/kafka/tools/automq/GenerateS3UrlCmd.java @@ -152,7 +152,7 @@ public String run() { // precheck String bucketURLStr = "0@s3://" + parameter.s3DataBucket - + "?region=" + parameter.s3Endpoint + + "?region=" + parameter.s3Region + "&endpoint=" + parameter.endpointProtocol.getName() + "://" + parameter.s3Endpoint + "&pathStyle=" + parameter.s3PathStyle; PingS3Helper pingS3Helper = PingS3Helper.builder()