Upgrade to Kafka 3.5

bakdata · Jan 17, 2024 · a7ebc7c · a7ebc7c
1 parent 6122a52
commit a7ebc7c
Showing 1 changed file with 1 addition and 2 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
@@ -39,7 +39,6 @@
 import io.confluent.connect.protobuf.ProtobufConverter;
 import io.confluent.kafka.schemaregistry.avro.AvroSchemaProvider;
 import io.confluent.kafka.schemaregistry.json.JsonSchemaProvider;
-import io.confluent.kafka.schemaregistry.protobuf.ProtobufSchema.ProtobufMeta;
 import io.confluent.kafka.schemaregistry.protobuf.ProtobufSchemaProvider;
 import io.confluent.kafka.schemaregistry.protobuf.dynamic.DynamicSchema;
 import io.confluent.kafka.schemaregistry.protobuf.dynamic.MessageDefinition;
@@ -162,7 +161,7 @@ private static DynamicMessage generateDynamicMessage() throws DescriptorValidati
         final DynamicSchema dynamicSchema = DynamicSchema.newBuilder()
                 .setName("file")
                 .addMessageDefinition(MessageDefinition.newBuilder("Test")
-                        .addField("", "string", "testId", 1, null, new ProtobufMeta(null, null, null))
+                        .addField(null, "string", "testId", 1, null, null)
                         .build())
                 .build();
         final Descriptor test = dynamicSchema.getMessageDescriptor("Test");