From c9040fe97c57436b3c152a5f899471e88e1c3690 Mon Sep 17 00:00:00 2001
From: asahi <mikiyashiki@outlook.com>
Date: Tue, 24 Feb 2026 02:09:42 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20kafka-compose=E9=85=8D=E7=BD=AE=E5=85=BC?=
 =?UTF-8?q?=E5=AE=B9=E6=B6=88=E8=B4=B9=E8=80=85=E7=BB=84=E8=AE=A2=E9=98=85?=
 =?UTF-8?q?=E6=8A=A5=E9=94=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修改kafka-compose配置文件中各broker实例的listener端口，避免消费者
组订阅报错
---
 kafka/docker-compose.yml | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/kafka/docker-compose.yml b/kafka/docker-compose.yml
index 365b0f0..17177fd 100644
--- a/kafka/docker-compose.yml
+++ b/kafka/docker-compose.yml
@@ -31,8 +31,8 @@ services:
       KAFKA_KRAFT_CLUSTER_ID: kafka-cluster-3-nodes # Define your cluster ID at .env file
       KAFKA_NODE_ID: 2
       KAFKA_PROCESS_ROLES: "broker,controller"
-      KAFKA_LISTENERS: INTERNAL://:9092,CONTROLLER://:9093,EXTERNAL://:19092
-      KAFKA_ADVERTISED_LISTENERS: INTERNAL://broker2:9092,EXTERNAL://localhost:19092
+      KAFKA_LISTENERS: INTERNAL://:9092,CONTROLLER://:9093,EXTERNAL://:19093
+      KAFKA_ADVERTISED_LISTENERS: INTERNAL://broker2:9092,EXTERNAL://localhost:19093
       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT
       KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
       KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
@@ -46,7 +46,7 @@ services:
     networks:
       - kafka-net
     ports:
-      - "19093:19092" # Expose external port for broker2
+      - "19093:19093" # Expose external port for broker2
     restart: unless-stopped
 
   broker3:
@@ -56,8 +56,8 @@ services:
       KAFKA_KRAFT_CLUSTER_ID: kafka-cluster-3-nodes # Define your cluster ID at .env file
       KAFKA_NODE_ID: 3
       KAFKA_PROCESS_ROLES: "broker,controller"
-      KAFKA_LISTENERS: INTERNAL://:9092,CONTROLLER://:9093,EXTERNAL://:19092
-      KAFKA_ADVERTISED_LISTENERS: INTERNAL://broker3:9092,EXTERNAL://localhost:19092
+      KAFKA_LISTENERS: INTERNAL://:9092,CONTROLLER://:9093,EXTERNAL://:19094
+      KAFKA_ADVERTISED_LISTENERS: INTERNAL://broker3:9092,EXTERNAL://localhost:19094
       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: INTERNAL:PLAINTEXT,CONTROLLER:PLAINTEXT,EXTERNAL:PLAINTEXT
       KAFKA_INTER_BROKER_LISTENER_NAME: INTERNAL
       KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER
@@ -71,7 +71,7 @@ services:
     networks:
       - kafka-net
     ports:
-      - "19094:19092" # Expose external port for broker3
+      - "19094:19094" # Expose external port for broker3
     restart: unless-stopped
 
   kafdrop: