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))