fix compiler warnings

Author: Karry

fs2-kafka/src/test/scala-2/com/avast/sst/fs2kafka/Fs2KafkaModuleTest.scala

@@ -1,7 +1,7 @@
 package com.avast.sst.fs2kafka
 
-import cats.effect.{IO, Resource}
-import cats.syntax.flatMap._
+import cats.effect.{ContextShift, IO, Resource, Timer}
+import cats.syntax.flatMap.*
 import com.dimafeng.testcontainers.{ForAllTestContainer, KafkaContainer}
 import fs2.kafka.{AutoOffsetReset, ProducerRecord, ProducerRecords}
 import org.scalatest.funsuite.AsyncFunSuite
@@ -10,10 +10,10 @@ import scala.concurrent.ExecutionContext.Implicits.global
 
 class Fs2KafkaModuleTest extends AsyncFunSuite with ForAllTestContainer {
 
-  override val container = KafkaContainer()
+  override val container: KafkaContainer = KafkaContainer()
 
-  implicit private val cs = IO.contextShift(global)
-  implicit private val timer = IO.timer(global)
+  implicit private val cs: ContextShift[IO] = IO.contextShift(global)
+  implicit private val timer: Timer[IO] = IO.timer(global)
 
   test("producer") {
     val io = for {

grpc-server/src/main/scala/com/avast/sst/grpc/server/interceptor/LoggingServerInterceptor.scala

@@ -5,6 +5,8 @@ import io.grpc.ForwardingServerCallListener.SimpleForwardingServerCallListener
 import io.grpc.*
 import org.slf4j.Logger
 
+import scala.annotation.nowarn
+
 /** Adds basic logging around each gRPC call. */
 class LoggingServerInterceptor(logger: Logger) extends ServerInterceptor {
 
@@ -18,6 +20,7 @@ class LoggingServerInterceptor(logger: Logger) extends ServerInterceptor {
     new OnMessageServerCallListener(methodName, next.startCall(finalCall, headers))
   }
 
+  @nowarn("msg=a type was inferred to be `Object`")
   private class CloseServerCall[A, B](methodName: String, delegate: ServerCall[A, B]) extends SimpleForwardingServerCall[A, B](delegate) {
     override def close(status: Status, trailers: Metadata): Unit = {
       import io.grpc.Status