Upgrade to Kafka 3.5

bakdata · Jan 16, 2024 · 31a6c34 · 31a6c34
1 parent 2d6ff3e
commit 31a6c34
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 10 deletions.
diff --git a/brute-force-connect/src/test/java/com/bakdata/kafka/BruteForceConverterTest.java b/brute-force-connect/src/test/java/com/bakdata/kafka/BruteForceConverterTest.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2022 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -125,7 +125,7 @@ private static DynamicMessage generateDynamicMessage() throws DescriptorValidati
         final DynamicSchema dynamicSchema = DynamicSchema.newBuilder()
                 .setName("file")
                 .addMessageDefinition(MessageDefinition.newBuilder("Test")
-                        .addField("", "string", "testId", 1, null, null, null)
+                        .addField("", "string", "testId", 1, null, null)
                         .build())
                 .build();
         final Descriptor test = dynamicSchema.getMessageDescriptor("Test");
@@ -158,8 +158,7 @@ private static Map<String, Object> getS3EndpointConfig() {
                 AbstractLargeMessageConfig.S3_ENDPOINT_CONFIG, "http://localhost:" + S3_MOCK.getHttpPort(),
                 AbstractLargeMessageConfig.S3_REGION_CONFIG, "us-east-1",
                 AbstractLargeMessageConfig.S3_ACCESS_KEY_CONFIG, "foo",
-                AbstractLargeMessageConfig.S3_SECRET_KEY_CONFIG, "bar",
-                AbstractLargeMessageConfig.S3_ENABLE_PATH_STYLE_ACCESS_CONFIG, true
+                AbstractLargeMessageConfig.S3_SECRET_KEY_CONFIG, "bar"
         );
     }
 

diff --git a/brute-force-serde/src/test/java/com/bakdata/kafka/BruteForceDeserializerTest.java b/brute-force-serde/src/test/java/com/bakdata/kafka/BruteForceDeserializerTest.java
@@ -1,7 +1,7 @@
 /*
  * MIT License
  *
- * Copyright (c) 2022 bakdata
+ * Copyright (c) 2024 bakdata
  *
  * Permission is hereby granted, free of charge, to any person obtaining a copy
  * of this software and associated documentation files (the "Software"), to deal
@@ -181,8 +181,7 @@ private static Map<String, Object> getS3EndpointConfig() {
                 AbstractLargeMessageConfig.S3_ENDPOINT_CONFIG, "http://localhost:" + S3_MOCK.getHttpPort(),
                 AbstractLargeMessageConfig.S3_REGION_CONFIG, "us-east-1",
                 AbstractLargeMessageConfig.S3_ACCESS_KEY_CONFIG, "foo",
-                AbstractLargeMessageConfig.S3_SECRET_KEY_CONFIG, "bar",
-                AbstractLargeMessageConfig.S3_ENABLE_PATH_STYLE_ACCESS_CONFIG, true
+                AbstractLargeMessageConfig.S3_SECRET_KEY_CONFIG, "bar"
         );
     }
 
@@ -329,7 +328,7 @@ void shouldReadGenericAvroKeys(final SerdeFactory<GenericRecord> factory) {
     void shouldReadBytesValues(final SerdeFactory<byte[]> factory) {
         final Properties properties = new Properties();
         // this makes StringDeserializer fail
-        properties.put("value.deserializer.encoding", "missing");
+        properties.setProperty("value.deserializer.encoding", "missing");
 
         final byte[] value = {1, 0};
         this.testValueTopology(factory, properties, Serdes.ByteArray(), value);
@@ -340,7 +339,7 @@ void shouldReadBytesValues(final SerdeFactory<byte[]> factory) {
     void shouldReadBytesKeys(final SerdeFactory<byte[]> factory) {
         final Properties properties = new Properties();
         // this makes StringDeserializer fail
-        properties.put("key.deserializer.encoding", "missing");
+        properties.setProperty("key.deserializer.encoding", "missing");
 
         final byte[] value = {1, 0};
         this.testKeyTopology(factory, properties, Serdes.ByteArray(), value);

diff --git a/build.gradle.kts b/build.gradle.kts
@@ -44,7 +44,7 @@ subprojects {
     apply(plugin = "java-library")
     apply(plugin = "io.freefair.lombok")
 
-    configure<JavaPluginConvention> {
+    configure<JavaPluginExtension> {
         sourceCompatibility = JavaVersion.VERSION_11
         targetCompatibility = JavaVersion.VERSION_11
     }