Reduced duplicate code

Author: germanosin

api/src/main/java/io/kafbat/ui/serdes/builtin/ConsumerOffsetsSerde.java

@@ -48,31 +48,11 @@ public static String name() {
     return "__consumer_offsets";
   }
 
-  @Override
-  public Optional<String> getDescription() {
-    return Optional.empty();
-  }
-
-  @Override
-  public Optional<SchemaDescription> getSchema(String topic, Target type) {
-    return Optional.empty();
-  }
-
   @Override
   public boolean canDeserialize(String topic, Target type) {
     return topic.equals(TOPIC);
   }
 
-  @Override
-  public boolean canSerialize(String topic, Target type) {
-    return false;
-  }
-
-  @Override
-  public Serializer serializer(String topic, Target type) {
-    throw new UnsupportedOperationException();
-  }
-
   @Override
   public Deserializer deserializer(String topic, Target type) {
     return switch (type) {

api/src/main/java/io/kafbat/ui/serdes/builtin/StructSerde.java

@@ -5,12 +5,16 @@
 import com.fasterxml.jackson.databind.SerializerProvider;
 import com.fasterxml.jackson.databind.json.JsonMapper;
 import com.fasterxml.jackson.databind.module.SimpleModule;
+import io.kafbat.ui.serde.api.SchemaDescription;
+import io.kafbat.ui.serde.api.Serde;
+import io.kafbat.ui.serdes.BuiltInSerde;
 import java.io.IOException;
+import java.util.Optional;
 import lombok.SneakyThrows;
 import org.apache.kafka.common.protocol.types.BoundField;
 import org.apache.kafka.common.protocol.types.Struct;
 
-public abstract class StructSerde {
+public abstract class StructSerde implements BuiltInSerde {
 
   private static final JsonMapper JSON_MAPPER = createMapper();
 
@@ -32,6 +36,31 @@ public void serialize(Struct value, JsonGenerator gen, SerializerProvider serial
     return mapper;
   }
 
+  @Override
+  public Optional<String> getDescription() {
+    return Optional.empty();
+  }
+
+  @Override
+  public Optional<SchemaDescription> getSchema(String topic, Serde.Target type) {
+    return Optional.empty();
+  }
+
+  @Override
+  public boolean canDeserialize(String topic, Serde.Target type) {
+    return true;
+  }
+
+  @Override
+  public boolean canSerialize(String topic, Serde.Target type) {
+    return false;
+  }
+
+  @Override
+  public Serde.Serializer serializer(String topic, Serde.Target type) {
+    throw new UnsupportedOperationException();
+  }
+
   @SneakyThrows
   protected String toJson(Struct s) {
     return JSON_MAPPER.writeValueAsString(s);

api/src/main/java/io/kafbat/ui/serdes/builtin/mm2/MirrorMakerSerde.java

@@ -1,8 +1,6 @@
 package io.kafbat.ui.serdes.builtin.mm2;
 
 import io.kafbat.ui.serde.api.DeserializeResult;
-import io.kafbat.ui.serde.api.SchemaDescription;
-import io.kafbat.ui.serde.api.Serde;
 import io.kafbat.ui.serdes.BuiltInSerde;
 import io.kafbat.ui.serdes.builtin.StructSerde;
 import java.nio.ByteBuffer;
@@ -17,31 +15,6 @@ abstract class MirrorMakerSerde extends StructSerde implements BuiltInSerde {
 
   protected final boolean versioned;
 
-  @Override
-  public Optional<String> getDescription() {
-    return Optional.empty();
-  }
-
-  @Override
-  public Optional<SchemaDescription> getSchema(String topic, Serde.Target type) {
-    return Optional.empty();
-  }
-
-  @Override
-  public boolean canDeserialize(String topic, Serde.Target type) {
-    return true;
-  }
-
-  @Override
-  public boolean canSerialize(String topic, Serde.Target type) {
-    return false;
-  }
-
-  @Override
-  public Serde.Serializer serializer(String topic, Serde.Target type) {
-    throw new UnsupportedOperationException();
-  }
-
   @Override
   public Deserializer deserializer(String topic, Target target) {
     return (recordHeaders, bytes) ->