From 0a1e21471ab8ce6f89c632fcb9bb71bb365c248a Mon Sep 17 00:00:00 2001 From: Andrew Mohrland Date: Mon, 30 Dec 2024 11:44:47 -0800 Subject: [PATCH] Add list of schema registry compatibility levels --- .../kafka/schemaregistry/SchemaRegistryApi.scala | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/core/src/main/scala/com/banno/kafka/schemaregistry/SchemaRegistryApi.scala b/core/src/main/scala/com/banno/kafka/schemaregistry/SchemaRegistryApi.scala index 69caba892..3b83cb6b4 100644 --- a/core/src/main/scala/com/banno/kafka/schemaregistry/SchemaRegistryApi.scala +++ b/core/src/main/scala/com/banno/kafka/schemaregistry/SchemaRegistryApi.scala @@ -224,6 +224,17 @@ object SchemaRegistryApi { fromString(s).getOrElse( throw ParseFailure(s"Unable to parse CompatibilityLevel: $s") ) + + val values: List[CompatibilityLevel] = + List( + Backward, + BackwardTransitive, + Forward, + ForwardTransitive, + Full, + FullTransitive, + None, + ) } def register[F[_]: Sync, K, V](