style: Apply scalafix and scalafmt changes

Author: piyush-zlai

flink/src/main/scala/ai/chronon/flink/deser/SchemaRegistrySerDe.scala

@@ -9,11 +9,11 @@ import io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientExcept
 import org.apache.avro.Schema
 
 /** Schema Provider / SerDe implementation that uses the Confluent Schema Registry to fetch schemas for topics.
- * Can be configured as: topic = "kafka://topic-name/registry_host=host/[registry_port=port]/[registry_scheme=http]/[subject=subject]"
- * Port, scheme and subject are optional. If port is missing, we assume the host is pointing to a LB address / such that
- * forwards to the right host + port. Scheme defaults to http. Subject defaults to the topic name + "-value" (based on schema
- * registry conventions).
- */
+  * Can be configured as: topic = "kafka://topic-name/registry_host=host/[registry_port=port]/[registry_scheme=http]/[subject=subject]"
+  * Port, scheme and subject are optional. If port is missing, we assume the host is pointing to a LB address / such that
+  * forwards to the right host + port. Scheme defaults to http. Subject defaults to the topic name + "-value" (based on schema
+  * registry conventions).
+  */
 class SchemaRegistrySerDe(topicInfo: TopicInfo) extends SerDe {
   import SchemaRegistrySerDe._
 
@@ -63,7 +63,7 @@ class SchemaRegistrySerDe(topicInfo: TopicInfo) extends SerDe {
           throw new IllegalArgumentException("Error connecting to and requesting schema details from the registry", e)
       }
     require(parsedSchema.schemaType() == AvroSchema.TYPE,
-      s"Unsupported schema type: ${parsedSchema.schemaType()}. Only Avro is supported.")
+            s"Unsupported schema type: ${parsedSchema.schemaType()}. Only Avro is supported.")
     val avroSchema: Schema = parsedSchema.asInstanceOf[AvroSchema].rawSchema()
     val chrononSchema: StructType = AvroConversions.toChrononSchema(avroSchema).asInstanceOf[StructType]
     (avroSchema, chrononSchema)
@@ -94,4 +94,4 @@ object SchemaRegistrySerDe {
   val RegistrySchemeKey = "registry_scheme"
   val RegistrySubjectKey = "subject"
   val SchemaRegistryWireFormat = "schema_registry_wire_format"
-}
+}