Update fs2-kafka to 1.2.0

build.sbt

@@ -182,7 +182,8 @@ lazy val fs2Kafka = project
     libraryDependencies ++= Seq(
       Dependencies.fs2Kafka,
       Dependencies.testContainersScalaScalaTest % Test,
-      Dependencies.testContainersScalaKafka % Test
+      Dependencies.testContainersScalaKafka % Test,
+      Dependencies.jacksonDatabind % Test
     )
   )
 

fs2-kafka/src/main/scala/com/avast/sst/fs2kafka/Fs2KafkaModule.scala

@@ -50,7 +50,7 @@ object Fs2KafkaModule {
 
   def makeConsumer[F[_]: ConcurrentEffect: ContextShift: Timer, K, V](
       settings: ConsumerSettings[F, K, V]
-  ): Resource[F, KafkaConsumer[F, K, V]] = consumerResource[F].using(settings)
+  ): Resource[F, KafkaConsumer[F, K, V]] = KafkaConsumer.resource[F, K, V](settings)
 
   def makeProducer[F[_]: ConcurrentEffect: ContextShift, K: Serializer[F, *], V: Serializer[F, *]](
       config: ProducerConfig,
@@ -86,7 +86,7 @@ object Fs2KafkaModule {
   }
 
   def makeProducer[F[_]: ConcurrentEffect: ContextShift, K, V](settings: ProducerSettings[F, K, V]): Resource[F, KafkaProducer[F, K, V]] =
-    producerResource[F].using(settings)
+    KafkaProducer.resource[F, K, V](settings)
 
   /** Copy of the same class from Scala 2.13 */
   implicit private final class ChainingOps[A](private val self: A) extends AnyVal {

project/Dependencies.scala

@@ -7,7 +7,7 @@ object Dependencies {
   val doobie = "org.tpolecat" %% "doobie-core" % Versions.doobie
   val doobieHikari = "org.tpolecat" %% "doobie-hikari" % Versions.doobie
   val flywayCore = "org.flywaydb" % "flyway-core" % "7.5.0"
-  val fs2Kafka = "com.github.fd4s" %% "fs2-kafka" % "1.1.0"
+  val fs2Kafka = "com.github.fd4s" %% "fs2-kafka" % "1.2.0"
   val grpcNettyShaded = "io.grpc" % "grpc-netty-shaded" % Versions.grpc
   val grpcProtobuf = "io.grpc" % "grpc-protobuf" % Versions.grpc
   val grpcStub = "io.grpc" % "grpc-stub" % Versions.grpc
@@ -16,6 +16,7 @@ object Dependencies {
   val http4sClient = "org.http4s" %% "http4s-client" % Versions.http4s
   val http4sDsl = "org.http4s" %% "http4s-dsl" % Versions.http4s
   val http4sServer = "org.http4s" %% "http4s-server" % Versions.http4s
+  val jacksonDatabind = "com.fasterxml.jackson.core" % "jackson-databind" % "2.12.1"
   val jsr305 = "com.google.code.findbugs" % "jsr305" % "3.0.2"
   val kindProjector = "org.typelevel" % "kind-projector" % "0.11.2" cross CrossVersion.full
   val lettuce = "io.lettuce" % "lettuce-core" % "6.0.2.RELEASE"

site/docs/subprojects/fs2-kafka.md

@@ -36,3 +36,6 @@ The configuration case classes contain an "escape hatch" into the full world of
 This is there to be flexible in case it is needed. Documentation of all the configuration properties is available here:
 * [consumer](http://kafka.apache.org/documentation/#consumerconfigs)
 * [producer](http://kafka.apache.org/documentation/#producerconfigs)
+
+Beware that there is an optional dependency on `jackson-databind` for the default implementation of `SASL/OAUTHBEARER` in `kafka-clients`.
+You need to provide it explicitly: https://kafka.apache.org/documentation/#security_sasl_oauthbearer_clientconfig