0ct0pu5/kafka-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use schema text in test

Browse source
This commit is contained in:
kostasdizas 2023-08-04 19:27:58 +01:00
parent 0c627a4d7b
commit 504962447b
No known key found for this signature in database
GPG key ID: 97876C44A0C60912
1 changed files with 9 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
kafka-ui-api/src/test/java/com/provectus/kafka/ui/serdes/builtin/ProtobufRawSerdeTest.java
View file

@ -8,6 +8,7 @@ import com.google.protobuf.Descriptors;
import com.google.protobuf.DynamicMessage;
import com.provectus.kafka.ui.exception.ValidationException;
import com.provectus.kafka.ui.serde.api.Serde;
import io.confluent.kafka.schemaregistry.protobuf.ProtobufSchema;
import lombok.SneakyThrows;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@ -25,28 +26,14 @@ class ProtobufRawSerdeTest {
@SneakyThrows
Descriptors.Descriptor getDescriptor() {
DescriptorProtos.FileDescriptorProto fileDescriptorProto = DescriptorProtos.FileDescriptorProto
.newBuilder()
.setSyntax("proto3")
.setName("test.proto")
.addMessageType(
DescriptorProtos.DescriptorProto.newBuilder()
.setName("MyMessage")
.addField(
DescriptorProtos.FieldDescriptorProto.newBuilder()
.setName("my_field")
.setNumber(1)
.setType(DescriptorProtos.FieldDescriptorProto.Type.TYPE_INT32)
.build()
)
.build()
)
.build();
Descriptors.FileDescriptor fileDescriptor = Descriptors.FileDescriptor.buildFrom(
fileDescriptorProto, new Descriptors.FileDescriptor[0]);
return fileDescriptor.findMessageTypeByName("MyMessage");
return new ProtobufSchema(
"""
syntax = "proto3";
message MyMessage {
int32 my_field = 1;
}
"""
).toDescriptor("MyMessage");
}
@SneakyThrows