diff --git a/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/kafkaOps.scala b/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/kafkaOps.scala
index b4c2da3..fa00cb6 100644
--- a/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/kafkaOps.scala
+++ b/embedded-kafka/src/main/scala/io/github/embeddedkafka/ops/kafkaOps.scala
@@ -21,6 +21,7 @@ import org.apache.kafka.server.config.{
   ServerConfigs,
   ServerLogConfigs
 }
+import org.apache.kafka.common.network.ListenerName
 import org.apache.kafka.storage.internals.log.CleanerConfig
 import org.slf4j.LoggerFactory
 
@@ -240,13 +241,17 @@ trait RunningKafkaOps {
 
   private[embeddedkafka] def kafkaPort(kafkaBrokerServer: BrokerServer): Int =
     kafkaBrokerServer.boundPort(
-      kafkaBrokerServer.config.listeners.head.listenerName
+      ListenerName.normalised(
+        kafkaBrokerServer.config.listeners.head.listener()
+      )
     )
 
   private[embeddedkafka] def controllerPort(
       controllerServer: ControllerServer
   ): Int =
     controllerServer.socketServer.boundPort(
-      controllerServer.config.controllerListeners.head.listenerName
+      ListenerName.normalised(
+        controllerServer.config.controllerListeners.head.listener()
+      )
     )
 }
diff --git a/project/Dependencies.scala b/project/Dependencies.scala
index d0110c8..615c04f 100644
--- a/project/Dependencies.scala
+++ b/project/Dependencies.scala
@@ -5,10 +5,10 @@ object Dependencies {
   object Versions {
     val Scala3    = "3.3.6"
     val Scala213  = "2.13.16"
-    val Kafka     = "4.0.0"
+    val Kafka     = "4.1.0"
     val Slf4j     = "1.7.36"
     val ScalaTest = "3.2.19"
-    val Jackson   = "2.16.2" // Keep consistent with the one provided by Kafka
+    val Jackson   = "2.19.0" // Keep consistent with the one provided by Kafka
   }
 
   object Common {