From: Kai Moritz Date: Thu, 17 Apr 2025 22:10:04 +0000 (+0200) Subject: Phase 4: Broker von Zookeeper auf die KRAF-Controller migrieren X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7d1305f96bed77bd955054f4670508948de8de6c;p=demos%2Fkafka%2Ftraining Phase 4: Broker von Zookeeper auf die KRAF-Controller migrieren * Rolling Upgrade der Broker notwendig: + [source] -- docker compose up kafka-1; docker compose logs --tail=10 -f kafka-1 docker compose up kafka-2; docker compose logs --tail=10 -f kafka-2 docker compose up kafka-3; docker compose logs --tail=10 -f kafka-3 -- --- diff --git a/docker-compose.yml b/docker-compose.yml index e0ebae4..af996af 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -80,16 +80,15 @@ services: kafka-1: image: confluentinc/cp-kafka:7.9.0 environment: + CLUSTER_ID: 8e-KqCzwQPqK7EibrzJE5g + KAFKA_PROCESS_ROLES: broker + KAFKA_NODE_ID: 1 KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER KAFKA_CONTROLLER_QUORUM_VOTERS: 101@controller-1:9092,102@controller-2:9092,103@controller-3:9092 - KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 - KAFKA_ZOOKEEPER_METADATA_MIGRATION_ENABLE: true KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9081 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:SASL_PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT, CONTROLLER:PLAINTEXT KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-1:9091, DOCKER://kafka-1:9092, LOCALHOST://localhost:9081 - KAFKA_BROKER_ID: 1 KAFKA_INTER_BROKER_LISTENER_NAME: BROKER - KAFKA_INTER_BROKER_PROTOCOL_VERSION: 3.9 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" KAFKA_SUPER_USERS: User:broker @@ -133,16 +132,15 @@ services: kafka-2: image: confluentinc/cp-kafka:7.9.0 environment: + CLUSTER_ID: 8e-KqCzwQPqK7EibrzJE5g + KAFKA_PROCESS_ROLES: broker + KAFKA_NODE_ID: 2 KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER KAFKA_CONTROLLER_QUORUM_VOTERS: 101@controller-1:9092,102@controller-2:9092,103@controller-3:9092 - KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 - KAFKA_ZOOKEEPER_METADATA_MIGRATION_ENABLE: true KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9082 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:SASL_PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT, CONTROLLER:PLAINTEXT KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-2:9091, DOCKER://kafka-2:9092, LOCALHOST://localhost:9082 - KAFKA_BROKER_ID: 2 KAFKA_INTER_BROKER_LISTENER_NAME: BROKER - KAFKA_INTER_BROKER_PROTOCOL_VERSION: 3.9 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" KAFKA_SUPER_USERS: User:broker @@ -191,16 +189,15 @@ services: kafka-3: image: confluentinc/cp-kafka:7.9.0 environment: + CLUSTER_ID: 8e-KqCzwQPqK7EibrzJE5g + KAFKA_PROCESS_ROLES: broker + KAFKA_NODE_ID: 3 KAFKA_CONTROLLER_LISTENER_NAMES: CONTROLLER KAFKA_CONTROLLER_QUORUM_VOTERS: 101@controller-1:9092,102@controller-2:9092,103@controller-3:9092 - KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181 - KAFKA_ZOOKEEPER_METADATA_MIGRATION_ENABLE: true KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9083 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:SASL_PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT, CONTROLLER:PLAINTEXT KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-3:9091, DOCKER://kafka-3:9092, LOCALHOST://localhost:9083 - KAFKA_BROKER_ID: 3 KAFKA_INTER_BROKER_LISTENER_NAME: BROKER - KAFKA_INTER_BROKER_PROTOCOL_VERSION: 3.9 KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3 KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false" KAFKA_SUPER_USERS: User:broker