deprecated old avro code

epiphanous · Dec 2, 2021 · 3ffd924 · 3ffd924
1 parent 4890d74
commit 3ffd924
Show file tree

Hide file tree

Showing 8 changed files with 44 additions and 0 deletions.
diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCoder.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCoder.scala
@@ -14,6 +14,10 @@ import scala.util.Try
  * @tparam Context
  *   the schema registry context type
  */
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 class AvroCoder[Context](registry: AvroSchemaRegistryClient[Context])
     extends LazyLogging {
 

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCodingException.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/AvroCodingException.scala
@@ -1,5 +1,9 @@
 package io.epiphanous.flinkrunner.avro
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 class AvroCodingException(
     message: String = "Failure during Avro coding",
     cause: Throwable = None.orNull)

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/AvroSchemaRegistryClient.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/AvroSchemaRegistryClient.scala
@@ -5,6 +5,10 @@ import scala.util.Try
 /**
  * A trait for an avro schema registry
  */
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 trait AvroSchemaRegistryClient[Context] {
 
   /**

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryClient.scala
@@ -19,6 +19,10 @@ import java.util.concurrent.TimeUnit
 import scala.concurrent.{ExecutionContext, ExecutionContextExecutor}
 import scala.util.{Failure, Success, Try}
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 class ConfluentSchemaRegistryClient[ADT <: FlinkEvent: TypeInformation](
     config: FlinkConfig[ADT])(implicit
     decoder: Decoder[ConfluentSchemaRegistryResponse])

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryContext.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryContext.scala
@@ -1,5 +1,9 @@
 package io.epiphanous.flinkrunner.avro
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 case class ConfluentSchemaRegistryContext(
     isKey: Boolean = false,
     version: String = "latest")
diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryResponse.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/ConfluentSchemaRegistryResponse.scala
@@ -5,18 +5,34 @@ import io.circe.generic.semiauto.{deriveDecoder, deriveEncoder}
 import io.circe.syntax._
 import io.circe.{Decoder, Encoder}
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 sealed trait ConfluentSchemaRegistryResponse {
   def schema: String
 }
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 case class ConfluentSchemaRegistryResponseById(schema: String)
     extends ConfluentSchemaRegistryResponse
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 object ConfluentSchemaRegistryResponseById {
   implicit val encoder = deriveEncoder[ConfluentSchemaRegistryResponseById]
   implicit val decoder = deriveDecoder[ConfluentSchemaRegistryResponseById]
 }
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 case class ConfluentSchemaRegistryResponseBySubjectVersion(
     subject: String,
     id: Int,

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/RegisteredAvroSchema.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/RegisteredAvroSchema.scala
@@ -8,6 +8,10 @@ import java.time.Instant
 import java.time.temporal.ChronoUnit
 import scala.util.Try
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 case class RegisteredAvroSchema(
     schema: Schema,
     id: String,

diff --git a/src/main/scala/io/epiphanous/flinkrunner/avro/TestSchemaRegistryClient.scala b/src/main/scala/io/epiphanous/flinkrunner/avro/TestSchemaRegistryClient.scala
@@ -4,6 +4,10 @@ import java.nio.ByteBuffer
 import scala.collection.mutable
 import scala.util.{Failure, Success, Try}
 
+@deprecated(
+  "Use the ConfluentAvroRegistryKafkaRecordSerialization and Deserialization classes instead",
+  "4.0.0"
+)
 class TestSchemaRegistryClient
     extends AvroSchemaRegistryClient[ConfluentSchemaRegistryContext] {
   val schemas =