diff --git a/large-message-core/src/main/java/com/bakdata/kafka/AbstractLargeMessageConfig.java b/large-message-core/src/main/java/com/bakdata/kafka/AbstractLargeMessageConfig.java index eeb9b98..a719819 100644 --- a/large-message-core/src/main/java/com/bakdata/kafka/AbstractLargeMessageConfig.java +++ b/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 scopes = Lists.newArrayList(GOOGLE_CLOUD_OAUTH_SCOPE); + final List scopes = List.of(GOOGLE_CLOUD_OAUTH_SCOPE); return GoogleCredentials.fromStream(credentialsStream).createScoped(scopes); } catch (final IOException ioException) { throw new UncheckedIOException( diff --git a/large-message-serde/build.gradle.kts b/large-message-serde/build.gradle.kts index 62d60b7..ad39b43 100644 --- a/large-message-serde/build.gradle.kts +++ b/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"))