diff --git a/src/test/java/io/oeid/mogakgo/core/kafka/producer/SimpleKafkaTest.java b/src/test/java/io/oeid/mogakgo/core/kafka/producer/SimpleKafkaTest.java index d744f293..a3212605 100644 --- a/src/test/java/io/oeid/mogakgo/core/kafka/producer/SimpleKafkaTest.java +++ b/src/test/java/io/oeid/mogakgo/core/kafka/producer/SimpleKafkaTest.java @@ -12,9 +12,9 @@ @SpringBootTest @EmbeddedKafka(partitions = 3, brokerProperties = { - "listeners=PLAINTEXT://localhost:9092" + "listeners=PLAINTEXT://localhost:49092" }, - ports = { 9092 }) + ports = { 49092 }) public class SimpleKafkaTest { @Autowired