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

SchemaRegistry serialization logic moved to one class, manual serializer creation removed

Browse source
This commit is contained in:
iliax 2023-08-14 17:27:48 +04:00
parent cbb0b023e2
commit 74d2b7fdbb
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
kafka-ui-api/src/main/java/com/provectus/kafka/ui/serdes/builtin/sr/Serialize.java
View file

@ -49,7 +49,7 @@ class Serialize {
throw new ValidationException(
String.format("'%s' does not fit schema: %s", value, e.getAllMessages()));
}
try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
try (var out = new ByteArrayOutputStream()) {
out.write(MAGIC);
out.write(schemaId(schemaId));
out.write(JSON_SERIALIZE_MAPPER.writeValueAsBytes(json));
@ -95,7 +95,7 @@ class Serialize {
@SneakyThrows
static byte[] serializeAvro(AvroSchema schema, int schemaId, String input) {
var avroObject = JsonAvroConversion.convertJsonToAvro(input, schema.rawSchema());
try (ByteArrayOutputStream out = new ByteArrayOutputStream()) {
try (var out = new ByteArrayOutputStream()) {
out.write(MAGIC);
out.write(schemaId(schemaId));
Schema rawSchema = schema.rawSchema();