GEOMESA-3455 Confluent Kafka - Close schema registry connection on dispose (#3297)

elahrvivaz · elahrvivaz · commit 1be34773f4bb · 2025-03-06T18:55:21.000-05:00
diff --git a/geomesa-kafka/geomesa-kafka-confluent/src/main/scala/org/locationtech/geomesa/kafka/confluent/ConfluentMetadata.scala b/geomesa-kafka/geomesa-kafka-confluent/src/main/scala/org/locationtech/geomesa/kafka/confluent/ConfluentMetadata.scala
@@ -80,7 +80,7 @@ class ConfluentMetadata(schemaRegistry: SchemaRegistryClient, sftOverrides: Map[
     }
   }
 
-  override def close(): Unit = {}
+  override def close(): Unit = schemaRegistry.close()
 
   override def scan(typeName: String, prefix: String, cache: Boolean): Seq[(String, String)] =
     throw new NotImplementedError(s"ConfluentMetadata only supports ${GeoMesaMetadata.AttributesKey}")

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ class ConfluentMetadata(schemaRegistry: SchemaRegistryClient, sftOverrides: Map[`
`80`	`80`	`}`
`81`	`81`	`}`
`82`	`82`
`83`		`- override def close(): Unit = {}`
	`83`	`+ override def close(): Unit = schemaRegistry.close()`
`84`	`84`
`85`	`85`	`override def scan(typeName: String, prefix: String, cache: Boolean): Seq[(String, String)] =`
`86`	`86`	`throw new NotImplementedError(s"ConfluentMetadata only supports ${GeoMesaMetadata.AttributesKey}")`