add Serializable to AvroCoder and AvroSchemaRegistryClient (#30)

* updates to build custom jar for dstreams * updated default schema registry versions * reading specific properties from env variables * reverting the review changes * reverted the changes * clean up plugins.sbt removed `sbt assembly` from plugins.sbt * reverted changes Co-authored-by: Steven Cambria <scambria@mdsol.com>
epiphanous · Dec 1, 2021 · 07a3939 · 07a3939
1 parent c96afd4
commit 07a3939
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCoder.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCoder.scala
@@ -15,7 +15,7 @@ import scala.util.Try
  *   the schema registry context type
  */
 class AvroCoder[Context](registry: AvroSchemaRegistryClient[Context])
-    extends LazyLogging {
+extends LazyLogging with Serializable {
 
   /**
    * Decode a given binary avro encoded byte array using a schema

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala
@@ -23,7 +23,8 @@ class ConfluentSchemaRegistryClient()(implicit
     decoder: Decoder[ConfluentSchemaRegistryResponse])
     extends AvroSchemaRegistryClient[ConfluentSchemaRegistryContext]
     with StringUtils
-    with LazyLogging {
+    with LazyLogging
+    with Serializable {
 
   import ConfluentSchemaRegistryClient.configPrefix