diff --git a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltFailOnErrorIntegrationTest.java b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltFailOnErrorIntegrationTest.java
index b20ee2ea12..b6ed08a0bc 100644
--- a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltFailOnErrorIntegrationTest.java
+++ b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltFailOnErrorIntegrationTest.java
@@ -24,7 +24,7 @@ import org.springframework.kafka.test.utils.ContainerTestUtils;
 import com.baeldung.spring.kafka.dlt.listener.PaymentListenerDltFailOnError;
 
 @SpringBootTest(classes = KafkaDltApplication.class)
-@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9099", "port=9099" })
+@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9096", "port=9096" })
 public class KafkaDltFailOnErrorIntegrationTest {
     private static final String TOPIC = "payments-fail-on-error-dlt";
 
diff --git a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltRetryOnErrorIntegrationTest.java b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltRetryOnErrorIntegrationTest.java
index 393eb2ae46..bd421e0cc8 100644
--- a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltRetryOnErrorIntegrationTest.java
+++ b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaDltRetryOnErrorIntegrationTest.java
@@ -25,7 +25,7 @@ import org.springframework.kafka.test.utils.ContainerTestUtils;
 import com.baeldung.spring.kafka.dlt.listener.PaymentListenerDltRetryOnError;
 
 @SpringBootTest(classes = KafkaDltApplication.class)
-@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9099", "port=9099" })
+@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9096", "port=9096" })
 public class KafkaDltRetryOnErrorIntegrationTest {
     private static final String TOPIC = "payments-retry-on-error-dlt";
 
diff --git a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaNoDltIntegrationTest.java b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaNoDltIntegrationTest.java
index 81cca9fec3..c792c975c1 100644
--- a/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaNoDltIntegrationTest.java
+++ b/spring-kafka-2/src/test/java/com/baeldung/spring/kafka/dlt/KafkaNoDltIntegrationTest.java
@@ -24,7 +24,7 @@ import org.springframework.kafka.test.utils.ContainerTestUtils;
 import com.baeldung.spring.kafka.dlt.listener.PaymentListenerNoDlt;
 
 @SpringBootTest(classes = KafkaDltApplication.class)
-@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9099", "port=9099" })
+@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9096", "port=9096" })
 public class KafkaNoDltIntegrationTest {
     private static final String TOPIC = "payments-no-dlt";