diff --git a/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/decoder/avro/confluent/ConfluentAvroKafkaStreamDecoder.scala b/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/decoder/avro/confluent/ConfluentAvroKafkaStreamDecoder.scala index a15b5530..e9d3bac1 100644 --- a/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/decoder/avro/confluent/ConfluentAvroKafkaStreamDecoder.scala +++ b/ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/decoder/avro/confluent/ConfluentAvroKafkaStreamDecoder.scala @@ -57,7 +57,10 @@ private[decoder] class ConfluentAvroKafkaStreamDecoder(val topic: String, val sc import za.co.absa.abris.avro.functions.from_confluent_avro import org.apache.spark.sql.functions.col - streamReader.load().select(from_confluent_avro(col("value"), schemaRegistryFullSettings) as 'data).select("data.*") + streamReader + .load() + .select(from_confluent_avro(col("value"), schemaRegistryFullSettings) as 'data) + .select("data.*") } } diff --git a/parent-conf/pom.xml b/parent-conf/pom.xml index ced1c386..ae1116ab 100644 --- a/parent-conf/pom.xml +++ b/parent-conf/pom.xml @@ -43,7 +43,7 @@ UTF-8 - 3.0.1 + 3.0.2 2.11.8 @@ -61,10 +61,10 @@ 2.1.1 2.2.4.RELEASE 0-10 - 2.4.2 + 2.4.3 - 2.4.0 + 2.4.3 2.25.0 @@ -148,7 +148,7 @@ za.co.absa - abris_2.11 + abris_${scala.compat.version} ${abris.version}