From f9318b23ea34d40a90210fe3b98864b1ea757bad Mon Sep 17 00:00:00 2001 From: Longyue Li Date: Sun, 29 Oct 2023 19:34:27 +0800 Subject: [PATCH] =?UTF-8?q?refactor:=20=E6=9B=BF=E6=8D=A2=E4=B8=BAkafka?= =?UTF-8?q?=E9=95=9C=E5=83=8F=E4=B8=BA3.6.0=E5=8E=BB=E6=8E=89zookeeper?= =?UTF-8?q?=E4=BE=9D=E8=B5=96=20(#10)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: longyue0521 --- e2e/kafka_test.go | 2 +- scripts/deploy/dev-compose.yaml | 35 ++++++++++++++------------------- 2 files changed, 16 insertions(+), 21 deletions(-) diff --git a/e2e/kafka_test.go b/e2e/kafka_test.go index bfc15b2..d312515 100644 --- a/e2e/kafka_test.go +++ b/e2e/kafka_test.go @@ -27,7 +27,7 @@ import ( ) func TestKafka(t *testing.T) { - address := []string{"127.0.0.1:9092"} + address := []string{"127.0.0.1:9094"} suite.Run(t, NewTestSuite(KafkaCreator{address: address})) } diff --git a/scripts/deploy/dev-compose.yaml b/scripts/deploy/dev-compose.yaml index d0a4563..cf6660a 100644 --- a/scripts/deploy/dev-compose.yaml +++ b/scripts/deploy/dev-compose.yaml @@ -1,21 +1,16 @@ -version: '3' +version: "3" services: - zookeeper: - image: 'bitnami/zookeeper:latest' - ports: - - '2181:2181' - environment: - - ALLOW_ANONYMOUS_LOGIN=yes - kafka: - image: 'bitnami/kafka:3.5.1' - ports: - - '9092:9092' - environment: - - KAFKA_BROKER_ID=1 - - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092 - - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:9092 - - KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181 - - ALLOW_PLAINTEXT_LISTENER=yes - - KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true - depends_on: - - zookeeper \ No newline at end of file + kafka0: + image: 'bitnami/kafka:3.6.0' + ports: + - '9092:9092' + - '9094:9094' + environment: + - KAFKA_CFG_NODE_ID=0 + - KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE=true + - KAFKA_CFG_PROCESS_ROLES=controller,broker + - KAFKA_CFG_LISTENERS=PLAINTEXT://:9092,CONTROLLER://:9093,EXTERNAL://:9094 + - KAFKA_CFG_ADVERTISED_LISTENERS=PLAINTEXT://kafka0:9094,EXTERNAL://localhost:9094 + - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP=CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT,PLAINTEXT:PLAINTEXT + - KAFKA_CFG_CONTROLLER_QUORUM_VOTERS=0@kafka0:9093 + - KAFKA_CFG_CONTROLLER_LISTENER_NAMES=CONTROLLER \ No newline at end of file