reenable ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest

epiphanous · Apr 23, 2023 · 6600e5c · 6600e5c
1 parent 2552110
commit 6600e5c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/...phanous/flinkrunner/serde/ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest.scala b/...phanous/flinkrunner/serde/ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest.scala
@@ -15,7 +15,7 @@ class ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest
     extends SerdeTestFixtures {
 
   // ignore until set up testcontainers schema registry
-  ignore("deserialize works for bwrapper") {
+  property("deserialize works for bwrapper") {
     val serde     = getDeserializerFor[BWrapper, BRecord]
     val collected = mutable.ArrayBuffer.empty[BWrapper]
     val collector = new Collector[BWrapper] {
@@ -29,7 +29,7 @@ class ConfluentAvroRegistryKafkaRecordDeserializationSchemaTest
     collected.head shouldEqual bWrapper
   }
 
-  ignore("deserialize works for awrapper") {
+  property("deserialize works for awrapper") {
     val serde     = getDeserializerFor[AWrapper, ARecord]
     val collected = mutable.ArrayBuffer.empty[AWrapper]
     val collector = new Collector[AWrapper] {

diff --git a/src/test/scala/io/epiphanous/flinkrunner/serde/SerdeTestFixtures.scala b/src/test/scala/io/epiphanous/flinkrunner/serde/SerdeTestFixtures.scala
@@ -135,7 +135,8 @@ trait SerdeTestFixtures extends PropSpec {
       A,
       MyAvroADT
     ](
-      kafkaSourceConfig
+      kafkaSourceConfig,
+      schemaRegistryClientOpt = Some(schemaRegistryClient)
     )
     ds.open(null)
     ds