Update kafka-clients to 3.7.0 (#1191)

Co-authored-by: zio-scala-steward[bot] <145262613+zio-scala-steward[bot]@users.noreply.github.com> Co-authored-by: jules Ivanic <[email protected]>
zio · Mar 11, 2024 · 5b84820 · 5b84820
1 parent 3d83277
commit 5b84820
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 6 deletions.
diff --git a/build.sbt b/build.sbt
@@ -1,7 +1,7 @@
 import sbt.Def
 
-lazy val kafkaVersion         = "3.6.1"
-lazy val embeddedKafkaVersion = "3.6.1" // Should be the same as kafkaVersion, except for the patch part
+lazy val kafkaVersion         = "3.7.0"
+lazy val embeddedKafkaVersion = "3.7.0" // Should be the same as kafkaVersion, except for the patch part
 
 lazy val kafkaClients          = "org.apache.kafka"        % "kafka-clients"           % kafkaVersion
 lazy val scalaCollectionCompat = "org.scala-lang.modules" %% "scala-collection-compat" % "2.11.0"

diff --git a/zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala b/zio-kafka/src/main/scala/zio/kafka/admin/AdminClient.scala
@@ -986,12 +986,17 @@ object AdminClient {
       override def asJava = JConfigResource.Type.UNKNOWN
     }
 
+    case object ClientMetrics extends ConfigResourceType {
+      override def asJava = JConfigResource.Type.CLIENT_METRICS
+    }
+
     def apply(jcrt: JConfigResource.Type): ConfigResourceType =
       jcrt match {
-        case JConfigResource.Type.BROKER_LOGGER => BrokerLogger
-        case JConfigResource.Type.BROKER        => Broker
-        case JConfigResource.Type.TOPIC         => Topic
-        case JConfigResource.Type.UNKNOWN       => Unknown
+        case JConfigResource.Type.BROKER_LOGGER  => BrokerLogger
+        case JConfigResource.Type.BROKER         => Broker
+        case JConfigResource.Type.TOPIC          => Topic
+        case JConfigResource.Type.UNKNOWN        => Unknown
+        case JConfigResource.Type.CLIENT_METRICS => ClientMetrics
       }
   }