diff --git a/build.sbt b/build.sbt
index 90ec3c8..3e91c76 100644
--- a/build.sbt
+++ b/build.sbt
@@ -1,6 +1,6 @@
 name := "kafkaquery"
 
-scalaVersion := "2.12.12"
+scalaVersion := "2.12.15"
 
 scalacOptions ++= Seq(
   "-deprecation",
@@ -15,11 +15,12 @@ packMain := Map(name.value -> "org.kafkaquery.CLI")
 packExtraClasspath := Map(name.value -> Seq("${PROG_HOME}/udf_dependencies/*"))
 
 lazy val flinkVersion       = "1.12.7"
-lazy val kafkaVersion       = "2.8.1"
-lazy val log4jVersion       = "2.14.1"
+lazy val kafkaVersion       = "3.1.0"
+lazy val log4jVersion       = "2.17.2"
 lazy val scalatestVersion   = "3.2.11"
 
 libraryDependencies ++= Seq(
+  // scala-steward:off
   "org.apache.logging.log4j"   % "log4j-api"                      % log4jVersion,
   "org.apache.logging.log4j"   % "log4j-core"                     % log4jVersion      % Runtime,
   "org.apache.logging.log4j"  %% "log4j-api-scala"                % "12.0",
@@ -31,16 +32,16 @@ libraryDependencies ++= Seq(
   "org.apache.flink"           % "flink-core"                     % flinkVersion      classifier "tests",
 
   "org.apache.zookeeper"       % "zookeeper"                      % "3.7.0",
-  "io.dropwizard.metrics"      % "metrics-core"                   % "4.1.31"          % Test,
+  "io.dropwizard.metrics"      % "metrics-core"                   % "4.2.9"           % Test,
 
   "org.scalactic"             %% "scalactic"                      % scalatestVersion  % Test,
   "org.scalatest"             %% "scalatest"                      % scalatestVersion  % Test,
-  "org.mockito"               %% "mockito-scala"                  % "1.16.55"         % Test,
+  "org.mockito"               %% "mockito-scala"                  % "1.17.5"          % Test,
 
   "org.apache.kafka"           % "kafka-clients"                  % kafkaVersion,
   "io.github.embeddedkafka"   %% "embedded-kafka"                 % kafkaVersion      % Test,
 
-  "org.apache.avro"            % "avro"                           % "1.10.2",
+  "org.apache.avro"            % "avro"                           % "1.11.0",
 
   "org.apache.flink"          %% "flink-table-api-scala-bridge"   % flinkVersion,
   "org.apache.flink"          %% "flink-table-planner-blink"      % flinkVersion,
diff --git a/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala b/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala
index f41c90d..2fac7ff 100644
--- a/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala
+++ b/src/test/scala/org/kafkaquery/commands/QueryCommandTest.scala
@@ -3,7 +3,7 @@ package org.kafkaquery.commands
 import java.io.{File, PrintWriter}
 import java.util
 import java.util.Collections
-import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
+import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
 import org.apache.avro.Schema
 import org.apache.flink.runtime.client.JobExecutionException
 import org.apache.flink.streaming.api.functions.sink.SinkFunction
diff --git a/src/test/scala/org/kafkaquery/parsers/ParserTest.scala b/src/test/scala/org/kafkaquery/parsers/ParserTest.scala
index aeca103..a3ffc6a 100644
--- a/src/test/scala/org/kafkaquery/parsers/ParserTest.scala
+++ b/src/test/scala/org/kafkaquery/parsers/ParserTest.scala
@@ -2,7 +2,7 @@ package org.kafkaquery.parsers
 
 import java.io.{ByteArrayOutputStream, File, PrintWriter}
 
-import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
+import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
 import org.apache.avro.Schema
 import org.apache.commons.io.FileUtils
 import org.kafkaquery.parsers.Configurations.Mode
@@ -80,8 +80,8 @@ class ParserTest extends AnyFunSuite with EmbeddedKafka with BeforeAndAfter {
       val res = new String(outStream.toByteArray)
       val otherOutStream = new java.io.ByteArrayOutputStream
       Console.withOut(otherOutStream)(parser.printTopics())
-      val res2 = new String(outStream.toByteArray)
-      assert(res.equals(res2))
+      val res_ = new String(outStream.toByteArray)
+      assert(res.equals(res_))
     }
   }
 
diff --git a/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala b/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala
index 55ca619..ca02806 100644
--- a/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala
+++ b/src/test/scala/org/kafkaquery/transforms/QueryOutputTest.scala
@@ -1,7 +1,7 @@
 package org.kafkaquery.transforms
 
-import net.manub.embeddedkafka.Codecs.stringDeserializer
-import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
+import io.github.embeddedkafka.Codecs.stringDeserializer
+import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
 import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration
 import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment, createTypeInformation}
 import org.apache.flink.test.util.MiniClusterWithClientResource
diff --git a/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala b/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala
index 048c6ce..37f023c 100644
--- a/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala
+++ b/src/test/scala/org/kafkaquery/util/KafkaRecordRetrieverTest.scala
@@ -1,6 +1,6 @@
 package org.kafkaquery.util
 
-import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
+import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
 import org.scalatest.{BeforeAndAfter, BeforeAndAfterAll}
 import org.scalatest.funsuite.AnyFunSuite
 
diff --git a/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala b/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala
index d127ea5..d0f5b9f 100644
--- a/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala
+++ b/src/test/scala/org/kafkaquery/util/UserInputRetrieverTest.scala
@@ -3,8 +3,6 @@ package org.kafkaquery.util
 import org.mockito.MockitoSugar
 import org.scalatest.funsuite.AnyFunSuite
 
-import scala.io.StdIn
-
 class UserInputRetrieverTest extends AnyFunSuite with MockitoSugar {
 
 
diff --git a/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala b/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala
index 0cb459c..8aff9ce 100644
--- a/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala
+++ b/src/test/scala/org/kafkaquery/util/ZookeeperSchemaExposerTest.scala
@@ -18,7 +18,7 @@
  */
 package org.kafkaquery.util
 
-import net.manub.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
+import io.github.embeddedkafka.{EmbeddedKafka, EmbeddedKafkaConfig}
 import org.apache.avro.Schema
 import org.scalatest.funsuite.AnyFunSuite
 import org.scalatest.{BeforeAndAfter, BeforeAndAfterAll}