Update

Author: philipp94831

large-message-core/src/main/java/com/bakdata/kafka/AbstractLargeMessageConfig.java

@@ -31,7 +31,6 @@
 import com.google.auth.oauth2.GoogleCredentials;
 import com.google.cloud.storage.StorageOptions;
 import com.google.common.collect.ImmutableMap;
-import com.google.common.collect.Lists;
 import java.io.File;
 import java.io.FileInputStream;
 import java.io.IOException;
@@ -383,7 +382,7 @@ private BlobStorageClient createGoogleStorageClient() {
 
     private GoogleCredentials getGoogleCredentials() {
         try (final FileInputStream credentialsStream = new FileInputStream(this.getString(GOOGLE_CLOUD_KEY_PATH))) {
-            final List<String> scopes = Lists.newArrayList(GOOGLE_CLOUD_OAUTH_SCOPE);
+            final List<String> scopes = List.of(GOOGLE_CLOUD_OAUTH_SCOPE);
             return GoogleCredentials.fromStream(credentialsStream).createScoped(scopes);
         } catch (final IOException ioException) {
             throw new UncheckedIOException(

large-message-serde/build.gradle.kts

@@ -25,6 +25,10 @@
 description = "Kafka serde that stores large messages on a blob storage, such as Amazon S3 and Azure Blob Storage"
 
 
+repositories {
+    mavenCentral()
+    maven(url = "https://packages.confluent.io/maven/")
+}
 
 dependencies {
     api(project(":large-message-core"))