Added tests for proto serdes

Author: singh-viikram

kafka-streams-serdes/build.gradle.kts

@@ -1,6 +1,7 @@
 plugins {
   `java-library`
   jacoco
+  id("com.google.protobuf") version "0.9.3"
   id("org.hypertrace.avro-plugin")
   id("org.hypertrace.publish-plugin")
   id("org.hypertrace.jacoco-report-plugin")
@@ -24,3 +25,11 @@ dependencies {
 tasks.named<org.hypertrace.gradle.avro.CheckAvroCompatibility>("avroCompatibilityCheck") {
   enabled = false
 }
+
+sourceSets {
+  test {
+    java {
+      srcDirs("src/test/proto") // Generated Proto classes
+    }
+  }
+}

kafka-streams-serdes/src/test/java/org/hypertrace/core/kafkastreams/framework/serdes/ProtoSerdeTest.java

@@ -0,0 +1,38 @@
+package org.hypertrace.core.kafkastreams.framework.serdes;
+
+import org.apache.kafka.common.serialization.Deserializer;
+import org.apache.kafka.common.serialization.Serializer;
+import org.hypertrace.core.kafkastreams.framework.serdes.proto.ProtoDeserializer;
+import org.hypertrace.core.kafkastreams.framework.serdes.proto.ProtoSerializer;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+import proto.TestProtoRecordOuterClass.TestProtoRecord;
+
+public class ProtoSerdeTest {
+
+  private static final String TEST_TOPIC = "test-topic";
+
+  // Subclass for testing with proto deserialization
+  public static class TestProtoRecordDeserializer extends ProtoDeserializer<TestProtoRecord> {
+    public TestProtoRecordDeserializer() {
+      super(TestProtoRecord.parser());
+    }
+  }
+
+  @Test
+  public void testSerialize() {
+    Serializer<TestProtoRecord> serializer = new ProtoSerializer<>();
+
+    Deserializer<TestProtoRecord> deserializer = new TestProtoRecordDeserializer();
+    TestProtoRecord message = TestProtoRecord.newBuilder().setId("id").build();
+
+    byte[] serializedData = serializer.serialize(TEST_TOPIC, message);
+
+    Assertions.assertNotNull(serializedData);
+    Assertions.assertTrue(serializedData.length > 0);
+
+    TestProtoRecord deserializedMessage = deserializer.deserialize(TEST_TOPIC, serializedData);
+
+    Assertions.assertEquals(message.getId(), deserializedMessage.getId());
+  }
+}

kafka-streams-serdes/src/test/proto/TestProtoRecord.proto

@@ -0,0 +1,7 @@
+syntax = "proto3";
+
+package proto;
+
+message TestProtoRecord {
+  string id = 1;
+}