diff --git a/ci/pod/docker-compose.plugin.yml b/ci/pod/docker-compose.plugin.yml
index 8ddeef20242e..f1f03ec294a2 100644
--- a/ci/pod/docker-compose.plugin.yml
+++ b/ci/pod/docker-compose.plugin.yml
@@ -109,8 +109,8 @@ services:
       KAFKA_CFG_ZOOKEEPER_CONNECT: zookeeper-server2:2181
     restart: unless-stopped
     ports:
-      - "19092:9092"
-      - "19094:9094"
+      - "19092:19092"
+      - "19094:19094"
     depends_on:
       - zookeeper-server1
       - zookeeper-server2
diff --git a/ci/pod/kafka/kafka-server/env/common2.env b/ci/pod/kafka/kafka-server/env/common2.env
index d07bf6d1ad58..c0fb5f57c95c 100644
--- a/ci/pod/kafka/kafka-server/env/common2.env
+++ b/ci/pod/kafka/kafka-server/env/common2.env
@@ -1,7 +1,7 @@
 ALLOW_PLAINTEXT_LISTENER=yes
 KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=false
-KAFKA_CFG_LISTENERS=PLAINTEXT://0.0.0.0:9092,SASL_PLAINTEXT://0.0.0.0:9094
-KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092,SASL_PLAINTEXT://127.0.0.1:9094
+KAFKA_CFG_LISTENERS=PLAINTEXT://0.0.0.0:19092,SASL_PLAINTEXT://0.0.0.0:19094
+KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:19092,SASL_PLAINTEXT://127.0.0.1:19094
 KAFKA_CFG_SSL_ENDPOINT_IDENTIFICATION_ALGORITHM=
 KAFKA_CFG_SSL_KEYSTORE_LOCATION=/opt/bitnami/kafka/config/certs/kafka.keystore.jks
 KAFKA_CFG_SSL_KEYSTORE_PASSWORD=changeit
diff --git a/t/plugin/kafka-logger.t b/t/plugin/kafka-logger.t
index 3ac9a0a08044..4ffef3ba10cb 100644
--- a/t/plugin/kafka-logger.t
+++ b/t/plugin/kafka-logger.t
@@ -669,7 +669,8 @@ failed to do PLAIN auth with 127.0.0.1:19094: Authentication failed: Invalid use
                                     "password":"admin-secret"
                             }
                         }],
-                            "kafka_topic":"test2",
+                            "kafka_topic":"test4",
+                            "producer_type":"sync",
                             "key":"key1",
                             "timeout":1,
                             "batch_max_size":1,
@@ -704,6 +705,8 @@ abcdef
 hello world
 --- error_log eval
 qr/send data to kafka: \{.*"body":"abcdef"/
+--- no_error_log
+[error]
 --- wait: 2