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: