Remove deprecated methods

aartigao · Oct 28, 2023 · ebb36b2 · ebb36b2
1 parent 15d32d9
commit ebb36b2
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 28 deletions.
diff --git a/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala b/modules/core/src/main/scala/fs2/kafka/AdminClientSettings.scala
@@ -231,13 +231,6 @@ object AdminClientSettings {
 
   }
 
-  @deprecated("use the overload that takes an argument for BootstrapServers", "2.0.0")
-  def apply: AdminClientSettings =
-    AdminClientSettingsImpl(
-      properties = Map.empty,
-      closeTimeout = 20.seconds
-    )
-
   def apply(bootstrapServers: String): AdminClientSettings =
     AdminClientSettingsImpl(
       properties = Map.empty,

diff --git a/modules/core/src/main/scala/fs2/kafka/package.scala b/modules/core/src/main/scala/fs2/kafka/package.scala
@@ -130,11 +130,6 @@ package kafka {
 
   object TransactionalProducerRecords {
 
-    @deprecated("this is now an identity operation", "3.0.0-M5")
-    def apply[F[_], K, V](
-      chunk: Chunk[CommittableProducerRecords[F, K, V]]
-    ): Chunk[CommittableProducerRecords[F, K, V]] = chunk
-
     /**
       * Creates a new [[TransactionalProducerRecords]] for producing exactly one
       * [[CommittableProducerRecords]]

diff --git a/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala b/modules/vulcan/src/main/scala/fs2/kafka/vulcan/AvroSettings.scala
@@ -104,12 +104,6 @@ sealed abstract class AvroSettings[F[_]] {
     writerSchema: Option[Schema]
   ): F[(KafkaAvroSerializer, SchemaRegistryClient)]
 
-  @deprecated("use the overload that takes an optional writer schema", "2.5.0-M3")
-  final def createAvroSerializer(
-    isKey: Boolean
-  ): F[(KafkaAvroSerializer, SchemaRegistryClient)] =
-    createAvroSerializer(isKey, writerSchema = None)
-
   /**
     * Creates a new [[AvroSettings]] instance with the specified function for creating
     * `KafkaAvroDeserializer`s from settings. The arguments are [[schemaRegistryClient]], `isKey`,
@@ -132,16 +126,6 @@ sealed abstract class AvroSettings[F[_]] {
     // format: on
   ): AvroSettings[F]
 
-  @deprecated("use the overload that has an `Option[Schema]` argument", "2.5.0-M3")
-  final def withCreateAvroSerializer(
-    // format: off
-    createAvroSerializerWith: (F[SchemaRegistryClient], Boolean, Map[String, String]) => F[(KafkaAvroSerializer, SchemaRegistryClient)]
-    // format: on
-  ): AvroSettings[F] =
-    withCreateAvroSerializer((client, isKey, _, properties) =>
-      createAvroSerializerWith(client, isKey, properties)
-    )
-
   /**
     * Creates a new [[AvroSettings]] instance with the specified function for registering schemas
     * from settings. The arguments are [[schemaRegistryClient]], `subject`, and `codec`.