diff --git a/avro/src/main/scala/com/ovoenergy/kafka/serialization/avro/JerseySchemaRegistryClient.scala b/avro/src/main/scala/com/ovoenergy/kafka/serialization/avro/JerseySchemaRegistryClient.scala index 2a74534..533162e 100644 --- a/avro/src/main/scala/com/ovoenergy/kafka/serialization/avro/JerseySchemaRegistryClient.scala +++ b/avro/src/main/scala/com/ovoenergy/kafka/serialization/avro/JerseySchemaRegistryClient.scala @@ -222,6 +222,23 @@ class JerseySchemaRegistryClient(settings: SchemaRegistryClientSettings) override def getId(subject: String, schema: Schema): Int = throw new UnsupportedOperationException + + override def deleteSchemaVersion(requestProperties: util.Map[String, String], + subject: String, + version: String): Integer = + throw new UnsupportedOperationException + + override def deleteSchemaVersion(subject: String, version: String): Integer = + throw new UnsupportedOperationException + + override def deleteSubject(requestProperties: util.Map[String, String], subject: String): util.List[Integer] = + throw new UnsupportedOperationException + + override def deleteSubject(subject: String): util.List[Integer] = + throw new UnsupportedOperationException + + override def getAllVersions(subject: String): util.List[Integer] = + throw new UnsupportedOperationException } object JerseySchemaRegistryClient { diff --git a/project/Dependencies.scala b/project/Dependencies.scala index fbb6bb3..7780656 100644 --- a/project/Dependencies.scala +++ b/project/Dependencies.scala @@ -79,9 +79,9 @@ object Dependencies { object kafka { - private val version = "0.11.0.1" + private val version = "1.1.0" - val avroSerializer = "io.confluent" % "kafka-avro-serializer" % "4.0.0" exclude ("org.slf4j", "slf4j-log4j12") + val avroSerializer = "io.confluent" % "kafka-avro-serializer" % "4.1.1" exclude ("org.slf4j", "slf4j-log4j12") val client = "org.apache.kafka" % "kafka-clients" % version exclude ("org.slf4j", "slf4j-log4j12") }