This is an automated email from the ASF dual-hosted git repository.
spacewander pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/apisix.git
The following commit(s) were added to refs/heads/master by this push:
new b440a06e0 ci: kafka should register port in the zookeeper same as
exposed (#8672)
b440a06e0 is described below
commit b440a06e0b01ed3b49233e6bf6971f13056ca7e1
Author: Peter Zhu <[email protected]>
AuthorDate: Wed Jan 18 09:58:18 2023 +0800
ci: kafka should register port in the zookeeper same as exposed (#8672)
---
ci/pod/docker-compose.plugin.yml | 4 ++--
ci/pod/kafka/kafka-server/env/common2.env | 4 ++--
t/plugin/kafka-logger.t | 5 ++++-
3 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/ci/pod/docker-compose.plugin.yml b/ci/pod/docker-compose.plugin.yml
index 8ddeef202..f1f03ec29 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 d07bf6d1a..c0fb5f57c 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 3ac9a0a08..4ffef3ba1 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
