diff --git a/build.sbt b/build.sbt index c7e205759..333db00fc 100644 --- a/build.sbt +++ b/build.sbt @@ -18,13 +18,13 @@ val vulcanVersion = "1.10.1" val munitVersion = "0.7.29" -val scala212 = "2.12.18" +val scala212 = "2.12.19" -val scala213 = "2.13.12" +val scala213 = "2.13.13" -val scala3 = "3.3.1" +val scala3 = "3.3.3" -ThisBuild / tlBaseVersion := "3.3" +ThisBuild / tlBaseVersion := "3.4" ThisBuild / tlCiReleaseBranches := Seq("series/3.x") diff --git a/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala b/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala index dd144da7a..e6cc5dc64 100644 --- a/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala +++ b/modules/core/src/main/scala/fs2/kafka/HeaderDeserializer.scala @@ -193,8 +193,8 @@ object HeaderDeserializer { HeaderDeserializer.instance { bytes => @tailrec def go(deserializer: HeaderDeserializer[Either[A, B]]): B = deserializer.deserialize(bytes) match { - case Right(b) => b - case Left(a) => go(f(a)) + case Right(_b) => _b + case Left(_a) => go(f(_a)) } go(f(a))