From 6636fc9e6cf4f5b68bf3f67d05a640ef4d76b017 Mon Sep 17 00:00:00 2001 From: Andrew Gustafson Date: Mon, 13 Sep 2021 20:38:45 +0930 Subject: [PATCH 1/7] Add AvroSettings.registerSchema method --- .../scala/fs2/kafka/vulcan/AvroSettings.scala | 27 ++++++++++++++++++- .../fs2/kafka/vulcan/AvroSettingsSpec.scala | 13 +++++++++ 2 files changed, 39 insertions(+), 1 deletion(-) diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala index 59a2bde0f..f0c3b23d2 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala @@ -10,6 +10,8 @@ import cats.effect.Sync import cats.implicits._ import fs2.kafka.internal.converters.collection._ import fs2.kafka.internal.syntax._ +import io.confluent.kafka.schemaregistry.avro.AvroSchema +import vulcan.Codec /** * Describes how to create a `KafkaAvroDeserializer` and a @@ -87,6 +89,9 @@ sealed abstract class AvroSettings[F[_]] { */ def createAvroDeserializer(isKey: Boolean): F[(KafkaAvroDeserializer, SchemaRegistryClient)] + // TODO + def registerSchema[A](subject: String)(implicit codec: Codec[A]): F[Int] + /** * Creates a new `KafkaAvroSerializer` using the settings * contained within this [[AvroSettings]] instance, and the @@ -118,6 +123,10 @@ sealed abstract class AvroSettings[F[_]] { createAvroSerializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroSerializer, SchemaRegistryClient)] // format: on ): AvroSettings[F] + + def withRegisterSchema( + registerSchemaWith: (F[SchemaRegistryClient], String, Codec[_]) => F[Int] + ): AvroSettings[F] } object AvroSettings { @@ -126,7 +135,8 @@ object AvroSettings { override val properties: Map[String, String], // format: off val createAvroDeserializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroDeserializer, SchemaRegistryClient)], - val createAvroSerializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroSerializer, SchemaRegistryClient)] + val createAvroSerializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroSerializer, SchemaRegistryClient)], + val registerSchemaWith: (F[SchemaRegistryClient], String, Codec[_]) => F[Int] // format: on ) extends AvroSettings[F] { override def withAutoRegisterSchemas(autoRegisterSchemas: Boolean): AvroSettings[F] = @@ -161,6 +171,9 @@ object AvroSettings { ): F[(KafkaAvroSerializer, SchemaRegistryClient)] = createAvroSerializerWith(schemaRegistryClient, isKey, properties) + override def registerSchema[A](subject: String)(implicit codec: Codec[A]): F[Int] = + registerSchemaWith(schemaRegistryClient, subject, codec) + override def withCreateAvroDeserializer( // format: off createAvroDeserializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroDeserializer, SchemaRegistryClient)] @@ -175,6 +188,11 @@ object AvroSettings { ): AvroSettings[F] = copy(createAvroSerializerWith = createAvroSerializerWith) + override def withRegisterSchema( + registerSchemaWith: (F[SchemaRegistryClient], String, Codec[_]) => F[Int] + ): AvroSettings[F] = + copy(registerSchemaWith = registerSchemaWith) + override def toString: String = "AvroSettings$" + System.identityHashCode(this) } @@ -203,7 +221,14 @@ object AvroSettings { serializer.configure(withDefaults(properties), isKey) (serializer, schemaRegistryClient) } + }, + registerSchemaWith = (schemaRegistryClient, subjectName, codec) => { + schemaRegistryClient.flatMap { client => + codec.schema.leftMap(_.throwable).liftTo[F].flatMap { schema => + F.delay(client.register(subjectName, new AvroSchema(schema))) + } } + } ) def apply[F[_]]( diff --git a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/AvroSettingsSpec.scala b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/AvroSettingsSpec.scala index 4e2730cb2..401faee2f 100644 --- a/modules/vulcan/src/test/scala/fs2/kafka/vulcan/AvroSettingsSpec.scala +++ b/modules/vulcan/src/test/scala/fs2/kafka/vulcan/AvroSettingsSpec.scala @@ -99,6 +99,19 @@ final class AvroSettingsSpec extends AnyFunSpec with ScalaCheckPropertyChecks { } } + it("should provide withRegisterSchema") { + assert { + settings + .withRegisterSchema { + case _ => IO.raiseError(new RuntimeException) + } + .registerSchema[String]("example-key") + .attempt + .unsafeRunSync() + .isLeft + } + } + it("should provide toString") { assert { settings.toString.startsWith("AvroSettings$") From 6a0d17e32212a02102e83047011e2f61c0035e38 Mon Sep 17 00:00:00 2001 From: Andrew Gustafson Date: Tue, 14 Sep 2021 13:33:53 +0930 Subject: [PATCH 2/7] Update docs --- .../src/main/scala/fs2/kafka/vulcan/AvroSettings.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala index f0c3b23d2..ca5c57c9c 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala @@ -89,7 +89,12 @@ sealed abstract class AvroSettings[F[_]] { */ def createAvroDeserializer(isKey: Boolean): F[(KafkaAvroDeserializer, SchemaRegistryClient)] - // TODO + /** + * Register a schema for a given `Codec` for some type `A`, + * or return the existing schema id if it already exists. + * @param subject The subject name + * @return The schema id + */ def registerSchema[A](subject: String)(implicit codec: Codec[A]): F[Int] /** From 6a9d1a8f4e8e7779742a675dc9e5455a5c8692c0 Mon Sep 17 00:00:00 2001 From: Andrew Gustafson Date: Tue, 14 Sep 2021 13:36:31 +0930 Subject: [PATCH 3/7] Update docs --- .../src/main/scala/fs2/kafka/vulcan/AvroSettings.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala index ca5c57c9c..e3269661f 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala @@ -129,6 +129,11 @@ sealed abstract class AvroSettings[F[_]] { // format: on ): AvroSettings[F] + /** + * Creates a new [[AvroSettings]] instance with the specified + * function for registering schemas from settings. + * The arguments are [[schemaRegistryClient]], `subject`, and `codec`. + */ def withRegisterSchema( registerSchemaWith: (F[SchemaRegistryClient], String, Codec[_]) => F[Int] ): AvroSettings[F] From 94e307b5c4045989a149777a06d9fa82af2bae8c Mon Sep 17 00:00:00 2001 From: Andrew Gustafson Date: Tue, 14 Sep 2021 16:05:25 +0930 Subject: [PATCH 4/7] Update docs; fix mima filters --- build.sbt | 7 ++++++- docs/src/main/mdoc/modules.md | 8 +++++++- 2 files changed, 13 insertions(+), 2 deletions(-) diff --git a/build.sbt b/build.sbt index 1c4f62563..e0c9d5276 100644 --- a/build.sbt +++ b/build.sbt @@ -270,7 +270,12 @@ lazy val mimaSettings = Seq( // format: off Seq( ProblemFilters.exclude[Problem]("fs2.kafka.internal.*"), - ProblemFilters.exclude[IncompatibleSignatureProblem]("*") + ProblemFilters.exclude[IncompatibleSignatureProblem]("*"), + ProblemFilters.exclude[ReversedMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings.registerSchema"), + ProblemFilters.exclude[ReversedMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings.withRegisterSchema"), + ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.copy"), + ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.this"), + ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.apply") ) // format: on } diff --git a/docs/src/main/mdoc/modules.md b/docs/src/main/mdoc/modules.md index 6d4a8cf3d..d0634e0ad 100644 --- a/docs/src/main/mdoc/modules.md +++ b/docs/src/main/mdoc/modules.md @@ -78,7 +78,7 @@ val producerSettings = .withBootstrapServers("localhost:9092") ``` -If we prefer, we can instead specificy the `Serializer`s and `Deserializer`s explicitly. +If we prefer, we can instead specify the `Serializer`s and `Deserializer`s explicitly. ```scala mdoc:silent import fs2.kafka.{Deserializer, Serializer} @@ -96,6 +96,12 @@ ProducerSettings( ).withBootstrapServers("localhost:9092") ``` +We can also register the schema with the registry server +```scala mdoc:silent +avroSettings.registerSchema[String]("person-key") *> + avroSettings.registerSchema[Person]("person-value") +``` + ### Sharing Client When creating `AvroSettings` with `SchemaRegistryClientSettings`, one schema registry client will be created per `Serializer` or `Deserializer`. For many cases, this is completely fine, but it's possible to reuse a single client for multiple `Serializer`s and `Deserializer`s. From a16628d8410e90eac8c6013730b6888d12139af8 Mon Sep 17 00:00:00 2001 From: Ben Plommer Date: Sat, 8 Jan 2022 13:44:15 +0000 Subject: [PATCH 5/7] Fix build.sbt --- build.sbt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/build.sbt b/build.sbt index 8df71ae5f..f1fbb19af 100644 --- a/build.sbt +++ b/build.sbt @@ -275,7 +275,7 @@ lazy val mimaSettings = Seq( ProblemFilters.exclude[ReversedMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings.withRegisterSchema"), ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.copy"), ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.this"), - ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.apply") + ProblemFilters.exclude[DirectMissingMethodProblem]("fs2.kafka.vulcan.AvroSettings#AvroSettingsImpl.apply"), ProblemFilters.exclude[ReversedMissingMethodProblem]("fs2.kafka.KafkaAdminClient.deleteConsumerGroups") ) // format: on From d2d12169a100f4645346e6105bfbe36075406d02 Mon Sep 17 00:00:00 2001 From: Ben Plommer Date: Sat, 8 Jan 2022 13:44:21 +0000 Subject: [PATCH 6/7] Revise doc --- docs/src/main/mdoc/modules.md | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/docs/src/main/mdoc/modules.md b/docs/src/main/mdoc/modules.md index f3bc483f6..bf7833fd4 100644 --- a/docs/src/main/mdoc/modules.md +++ b/docs/src/main/mdoc/modules.md @@ -96,10 +96,12 @@ ProducerSettings( ).withBootstrapServers("localhost:9092") ``` -We can also register the schema with the registry server +By default, a schema will automatically be registered when used to publish a message. We can disable this behaviour by +using `withAutoRegisterSchemas(false)`. We can then use `registerSchema` to manually register the schema with the registry server: ```scala mdoc:silent -avroSettings.registerSchema[String]("person-key") *> - avroSettings.registerSchema[Person]("person-value") +val avroSettingsWithoutAutoRegister = avroSettings.withAutoRegisterSchemas(false) +avroSettingsWithoutAutoRegister.registerSchema[String]("person-key") *> + avroSettingsWithoutAutoRegister.registerSchema[Person]("person-value") ``` ### Sharing Client From 7a82e547bf3ef261a53e3590cf5884417bb2b782 Mon Sep 17 00:00:00 2001 From: Ben Plommer Date: Sat, 8 Jan 2022 14:32:42 +0000 Subject: [PATCH 7/7] Update headers --- .../src/main/scala-2.12/fs2/kafka/internal/converters.scala | 2 +- .../src/main/scala-2.13+/fs2/kafka/internal/converters.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Acks.scala | 2 +- modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala | 2 +- modules/core/src/main/scala/fs2/kafka/AutoOffsetReset.scala | 2 +- modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala | 2 +- .../core/src/main/scala/fs2/kafka/CommitRecoveryException.scala | 2 +- .../core/src/main/scala/fs2/kafka/CommitTimeoutException.scala | 2 +- .../src/main/scala/fs2/kafka/CommittableConsumerRecord.scala | 2 +- modules/core/src/main/scala/fs2/kafka/CommittableOffset.scala | 2 +- .../core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala | 2 +- .../src/main/scala/fs2/kafka/CommittableProducerRecords.scala | 2 +- .../core/src/main/scala/fs2/kafka/ConsumerGroupException.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala | 2 +- .../src/main/scala/fs2/kafka/ConsumerShutdownException.scala | 2 +- .../src/main/scala/fs2/kafka/DeserializationException.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Deserializer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Header.scala | 2 +- modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/HeaderSerializer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Headers.scala | 2 +- modules/core/src/main/scala/fs2/kafka/IsolationLevel.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Jitter.scala | 2 +- modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala | 2 +- modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala | 2 +- .../core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala | 2 +- .../core/src/main/scala/fs2/kafka/NotSubscribedException.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ProducerRecords.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ProducerResult.scala | 2 +- modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala | 2 +- modules/core/src/main/scala/fs2/kafka/RecordDeserializer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/RecordSerializer.scala | 2 +- .../core/src/main/scala/fs2/kafka/SerializationException.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Serializer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/Timestamp.scala | 2 +- .../src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala | 2 +- .../src/main/scala/fs2/kafka/TransactionalProducerRecords.scala | 2 +- .../main/scala/fs2/kafka/TransactionalProducerSettings.scala | 2 +- .../src/main/scala/fs2/kafka/UnexpectedTopicException.scala | 2 +- modules/core/src/main/scala/fs2/kafka/admin/MkAdminClient.scala | 2 +- .../src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala | 2 +- .../core/src/main/scala/fs2/kafka/consumer/KafkaCommit.scala | 2 +- .../core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala | 2 +- .../main/scala/fs2/kafka/consumer/KafkaConsumerLifecycle.scala | 2 +- .../core/src/main/scala/fs2/kafka/consumer/KafkaMetrics.scala | 2 +- .../core/src/main/scala/fs2/kafka/consumer/KafkaOffsets.scala | 2 +- .../src/main/scala/fs2/kafka/consumer/KafkaSubscription.scala | 2 +- .../core/src/main/scala/fs2/kafka/consumer/KafkaTopics.scala | 2 +- modules/core/src/main/scala/fs2/kafka/consumer/MkConsumer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/instances.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/FakeFiber.scala | 2 +- .../src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/LogLevel.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/Logging.scala | 2 +- .../src/main/scala/fs2/kafka/internal/WithAdminClient.scala | 2 +- .../core/src/main/scala/fs2/kafka/internal/WithConsumer.scala | 2 +- .../core/src/main/scala/fs2/kafka/internal/WithProducer.scala | 2 +- modules/core/src/main/scala/fs2/kafka/internal/syntax.scala | 2 +- modules/core/src/main/scala/fs2/kafka/package.scala | 2 +- modules/core/src/main/scala/fs2/kafka/producer/MkProducer.scala | 2 +- .../main/scala/fs2/kafka/security/KafkaCredentialStore.scala | 2 +- .../src/main/scala/fs2/kafka/vulcan/testkit/SchemaSuite.scala | 2 +- modules/vulcan/src/main/scala/fs2/kafka/vulcan/Auth.scala | 2 +- .../src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala | 2 +- .../vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala | 2 +- .../vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala | 2 +- .../scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala | 2 +- modules/vulcan/src/main/scala/fs2/kafka/vulcan/package.scala | 2 +- 73 files changed, 73 insertions(+), 73 deletions(-) diff --git a/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala b/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala index 0a6d947b3..2ecfeb9b8 100644 --- a/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala +++ b/modules/core/src/main/scala-2.12/fs2/kafka/internal/converters.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala-2.13+/fs2/kafka/internal/converters.scala b/modules/core/src/main/scala-2.13+/fs2/kafka/internal/converters.scala index 32e41a71a..7a6f9f0a9 100644 --- a/modules/core/src/main/scala-2.13+/fs2/kafka/internal/converters.scala +++ b/modules/core/src/main/scala-2.13+/fs2/kafka/internal/converters.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Acks.scala b/modules/core/src/main/scala/fs2/kafka/Acks.scala index b52e5dcb7..2a0605d85 100644 --- a/modules/core/src/main/scala/fs2/kafka/Acks.scala +++ b/modules/core/src/main/scala/fs2/kafka/Acks.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala b/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala index 45fe49106..1fe20305d 100644 --- a/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala +++ b/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/AutoOffsetReset.scala b/modules/core/src/main/scala/fs2/kafka/AutoOffsetReset.scala index 351bacef9..8705e4828 100644 --- a/modules/core/src/main/scala/fs2/kafka/AutoOffsetReset.scala +++ b/modules/core/src/main/scala/fs2/kafka/AutoOffsetReset.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala b/modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala index 9868d9de2..f0b6b9f91 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommitRecovery.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommitRecoveryException.scala b/modules/core/src/main/scala/fs2/kafka/CommitRecoveryException.scala index 5a86aa9cd..c46067c37 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommitRecoveryException.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommitRecoveryException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommitTimeoutException.scala b/modules/core/src/main/scala/fs2/kafka/CommitTimeoutException.scala index 8317c8b4f..0b43990da 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommitTimeoutException.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommitTimeoutException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommittableConsumerRecord.scala b/modules/core/src/main/scala/fs2/kafka/CommittableConsumerRecord.scala index a455bb210..b82913039 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommittableConsumerRecord.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommittableConsumerRecord.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommittableOffset.scala b/modules/core/src/main/scala/fs2/kafka/CommittableOffset.scala index 02518eed7..aca1d7e93 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommittableOffset.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommittableOffset.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala b/modules/core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala index dc1b8a770..dca095c93 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommittableOffsetBatch.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/CommittableProducerRecords.scala b/modules/core/src/main/scala/fs2/kafka/CommittableProducerRecords.scala index 69aac53e6..09f0cc1b5 100644 --- a/modules/core/src/main/scala/fs2/kafka/CommittableProducerRecords.scala +++ b/modules/core/src/main/scala/fs2/kafka/CommittableProducerRecords.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerGroupException.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerGroupException.scala index 5f3964abd..87e8790f1 100644 --- a/modules/core/src/main/scala/fs2/kafka/ConsumerGroupException.scala +++ b/modules/core/src/main/scala/fs2/kafka/ConsumerGroupException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala index 9c69003e2..5de7bba55 100644 --- a/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala +++ b/modules/core/src/main/scala/fs2/kafka/ConsumerRecord.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala index 33103d411..6e1582f83 100644 --- a/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala +++ b/modules/core/src/main/scala/fs2/kafka/ConsumerSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ConsumerShutdownException.scala b/modules/core/src/main/scala/fs2/kafka/ConsumerShutdownException.scala index 339099689..a4e2665f7 100644 --- a/modules/core/src/main/scala/fs2/kafka/ConsumerShutdownException.scala +++ b/modules/core/src/main/scala/fs2/kafka/ConsumerShutdownException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/DeserializationException.scala b/modules/core/src/main/scala/fs2/kafka/DeserializationException.scala index 15c6dfb00..3b296dd96 100644 --- a/modules/core/src/main/scala/fs2/kafka/DeserializationException.scala +++ b/modules/core/src/main/scala/fs2/kafka/DeserializationException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Deserializer.scala b/modules/core/src/main/scala/fs2/kafka/Deserializer.scala index aef8bd258..ba397143a 100644 --- a/modules/core/src/main/scala/fs2/kafka/Deserializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/Deserializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Header.scala b/modules/core/src/main/scala/fs2/kafka/Header.scala index 323f3e9b3..e8d89bad9 100644 --- a/modules/core/src/main/scala/fs2/kafka/Header.scala +++ b/modules/core/src/main/scala/fs2/kafka/Header.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala b/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala index 69fae1d29..114f94b57 100644 --- a/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/HeaderSerializer.scala b/modules/core/src/main/scala/fs2/kafka/HeaderSerializer.scala index 458f049f6..5c2fbd8d8 100644 --- a/modules/core/src/main/scala/fs2/kafka/HeaderSerializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/HeaderSerializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Headers.scala b/modules/core/src/main/scala/fs2/kafka/Headers.scala index 360ee37d0..09930a1e8 100644 --- a/modules/core/src/main/scala/fs2/kafka/Headers.scala +++ b/modules/core/src/main/scala/fs2/kafka/Headers.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/IsolationLevel.scala b/modules/core/src/main/scala/fs2/kafka/IsolationLevel.scala index ef7828f17..18670be77 100644 --- a/modules/core/src/main/scala/fs2/kafka/IsolationLevel.scala +++ b/modules/core/src/main/scala/fs2/kafka/IsolationLevel.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Jitter.scala b/modules/core/src/main/scala/fs2/kafka/Jitter.scala index b0eaec971..d18ab9d03 100644 --- a/modules/core/src/main/scala/fs2/kafka/Jitter.scala +++ b/modules/core/src/main/scala/fs2/kafka/Jitter.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala b/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala index ba8006c89..9b928a36b 100644 --- a/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala +++ b/modules/core/src/main/scala/fs2/kafka/KafkaAdminClient.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala index 842e471bf..2f4013581 100644 --- a/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala +++ b/modules/core/src/main/scala/fs2/kafka/KafkaConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala b/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala index cc61796e7..50aae4b75 100644 --- a/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala +++ b/modules/core/src/main/scala/fs2/kafka/KafkaProducer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala b/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala index 1ca6fbd63..5d1243364 100644 --- a/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala +++ b/modules/core/src/main/scala/fs2/kafka/KafkaProducerConnection.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala b/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala index ad7dbe302..7f0e2cb11 100644 --- a/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala +++ b/modules/core/src/main/scala/fs2/kafka/NotSubscribedException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala b/modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala index 4f8ec6a82..2bd45c799 100644 --- a/modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala +++ b/modules/core/src/main/scala/fs2/kafka/ProducerRecord.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ProducerRecords.scala b/modules/core/src/main/scala/fs2/kafka/ProducerRecords.scala index 3eedcbacc..576565d07 100644 --- a/modules/core/src/main/scala/fs2/kafka/ProducerRecords.scala +++ b/modules/core/src/main/scala/fs2/kafka/ProducerRecords.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ProducerResult.scala b/modules/core/src/main/scala/fs2/kafka/ProducerResult.scala index 573d3ddd8..248a09224 100644 --- a/modules/core/src/main/scala/fs2/kafka/ProducerResult.scala +++ b/modules/core/src/main/scala/fs2/kafka/ProducerResult.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala b/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala index 4482eada7..fd7e30b14 100644 --- a/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala +++ b/modules/core/src/main/scala/fs2/kafka/ProducerSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/RecordDeserializer.scala b/modules/core/src/main/scala/fs2/kafka/RecordDeserializer.scala index 0609a75a1..fdc16c523 100644 --- a/modules/core/src/main/scala/fs2/kafka/RecordDeserializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/RecordDeserializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/RecordSerializer.scala b/modules/core/src/main/scala/fs2/kafka/RecordSerializer.scala index 7f59691e7..4145b145b 100644 --- a/modules/core/src/main/scala/fs2/kafka/RecordSerializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/RecordSerializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/SerializationException.scala b/modules/core/src/main/scala/fs2/kafka/SerializationException.scala index c68b6d1d4..afa279c14 100644 --- a/modules/core/src/main/scala/fs2/kafka/SerializationException.scala +++ b/modules/core/src/main/scala/fs2/kafka/SerializationException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Serializer.scala b/modules/core/src/main/scala/fs2/kafka/Serializer.scala index aefda5165..36eb1333b 100644 --- a/modules/core/src/main/scala/fs2/kafka/Serializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/Serializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/Timestamp.scala b/modules/core/src/main/scala/fs2/kafka/Timestamp.scala index 93242b202..d66ec3aeb 100644 --- a/modules/core/src/main/scala/fs2/kafka/Timestamp.scala +++ b/modules/core/src/main/scala/fs2/kafka/Timestamp.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala b/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala index d727202b6..d30683ca1 100644 --- a/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala +++ b/modules/core/src/main/scala/fs2/kafka/TransactionalKafkaProducer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/TransactionalProducerRecords.scala b/modules/core/src/main/scala/fs2/kafka/TransactionalProducerRecords.scala index b9a71a9eb..f6db4af61 100644 --- a/modules/core/src/main/scala/fs2/kafka/TransactionalProducerRecords.scala +++ b/modules/core/src/main/scala/fs2/kafka/TransactionalProducerRecords.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/TransactionalProducerSettings.scala b/modules/core/src/main/scala/fs2/kafka/TransactionalProducerSettings.scala index 3a0a02e8d..aa5c132e2 100644 --- a/modules/core/src/main/scala/fs2/kafka/TransactionalProducerSettings.scala +++ b/modules/core/src/main/scala/fs2/kafka/TransactionalProducerSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/UnexpectedTopicException.scala b/modules/core/src/main/scala/fs2/kafka/UnexpectedTopicException.scala index a0e100bf6..05723cd29 100644 --- a/modules/core/src/main/scala/fs2/kafka/UnexpectedTopicException.scala +++ b/modules/core/src/main/scala/fs2/kafka/UnexpectedTopicException.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/admin/MkAdminClient.scala b/modules/core/src/main/scala/fs2/kafka/admin/MkAdminClient.scala index aede8d8cf..dd3f98c6b 100644 --- a/modules/core/src/main/scala/fs2/kafka/admin/MkAdminClient.scala +++ b/modules/core/src/main/scala/fs2/kafka/admin/MkAdminClient.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala index 49e9f84c1..5d1d0dd3a 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaAssignment.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaCommit.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaCommit.scala index b1d655099..0f821394d 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaCommit.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaCommit.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala index 1e644773a..7ca371454 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsume.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsumerLifecycle.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsumerLifecycle.scala index ef4992e49..09ff210ce 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsumerLifecycle.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaConsumerLifecycle.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaMetrics.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaMetrics.scala index 6356b2b21..5fe271dce 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaMetrics.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaMetrics.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaOffsets.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaOffsets.scala index bdd10b183..52d9b7564 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaOffsets.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaOffsets.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaSubscription.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaSubscription.scala index 1fe8bb260..c47f73cc9 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaSubscription.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaSubscription.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaTopics.scala b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaTopics.scala index afa72a973..79f611247 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/KafkaTopics.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/KafkaTopics.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/consumer/MkConsumer.scala b/modules/core/src/main/scala/fs2/kafka/consumer/MkConsumer.scala index 098ba16f1..ccd0d2115 100644 --- a/modules/core/src/main/scala/fs2/kafka/consumer/MkConsumer.scala +++ b/modules/core/src/main/scala/fs2/kafka/consumer/MkConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/instances.scala b/modules/core/src/main/scala/fs2/kafka/instances.scala index b113ba144..e740ac72e 100644 --- a/modules/core/src/main/scala/fs2/kafka/instances.scala +++ b/modules/core/src/main/scala/fs2/kafka/instances.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala b/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala index c9ee8486c..2c005d287 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/Blocking.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/FakeFiber.scala b/modules/core/src/main/scala/fs2/kafka/internal/FakeFiber.scala index d281ddf72..e55a0ee9e 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/FakeFiber.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/FakeFiber.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala b/modules/core/src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala index 075c0d7c9..289895397 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/KafkaConsumerActor.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala b/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala index 1e2e25b89..c0b41726d 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/LogEntry.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/LogLevel.scala b/modules/core/src/main/scala/fs2/kafka/internal/LogLevel.scala index 409668415..87f1c2100 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/LogLevel.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/LogLevel.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala b/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala index 5645857c4..362b8ca41 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/Logging.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala index 46a607e9a..c8577030c 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/WithAdminClient.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala index a7c6fcfb5..cbe604eaf 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/WithConsumer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala b/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala index ded13fe8e..632e98778 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/WithProducer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala b/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala index 295fca5ba..7279d806a 100644 --- a/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala +++ b/modules/core/src/main/scala/fs2/kafka/internal/syntax.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/package.scala b/modules/core/src/main/scala/fs2/kafka/package.scala index 548689b5d..6109c6df7 100644 --- a/modules/core/src/main/scala/fs2/kafka/package.scala +++ b/modules/core/src/main/scala/fs2/kafka/package.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/producer/MkProducer.scala b/modules/core/src/main/scala/fs2/kafka/producer/MkProducer.scala index ea5d07bd9..e9d1c476c 100644 --- a/modules/core/src/main/scala/fs2/kafka/producer/MkProducer.scala +++ b/modules/core/src/main/scala/fs2/kafka/producer/MkProducer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/core/src/main/scala/fs2/kafka/security/KafkaCredentialStore.scala b/modules/core/src/main/scala/fs2/kafka/security/KafkaCredentialStore.scala index dd9aec407..bddf99208 100644 --- a/modules/core/src/main/scala/fs2/kafka/security/KafkaCredentialStore.scala +++ b/modules/core/src/main/scala/fs2/kafka/security/KafkaCredentialStore.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan-testkit-munit/src/main/scala/fs2/kafka/vulcan/testkit/SchemaSuite.scala b/modules/vulcan-testkit-munit/src/main/scala/fs2/kafka/vulcan/testkit/SchemaSuite.scala index 5bfa03a74..9dba8bdc2 100644 --- a/modules/vulcan-testkit-munit/src/main/scala/fs2/kafka/vulcan/testkit/SchemaSuite.scala +++ b/modules/vulcan-testkit-munit/src/main/scala/fs2/kafka/vulcan/testkit/SchemaSuite.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/Auth.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/Auth.scala index 1163eb9e0..b391204c4 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/Auth.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/Auth.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala index 70260e53f..c00918248 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroDeserializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala index 06e6eb74b..568e1c251 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSerializer.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala index ebfca4cf8..d6e645c4c 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala index e7365e0ee..0f36ab6c3 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/SchemaRegistryClientSettings.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */ diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/package.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/package.scala index bb48ed92b..39a394f14 100644 --- a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/package.scala +++ b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/package.scala @@ -1,5 +1,5 @@ /* - * Copyright 2018-2021 OVO Energy Limited + * Copyright 2018-2022 OVO Energy Limited * * SPDX-License-Identifier: Apache-2.0 */