From: Kai Moritz Date: Sun, 27 Apr 2025 12:23:17 +0000 (+0200) Subject: WIP:sasl-client--broker-angepasst--admin-properties X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=09d798376b733f8aef4c62e1973c9615d554be1d;p=demos%2Fkafka%2Ftraining WIP:sasl-client--broker-angepasst--admin-properties --- diff --git a/README.sh b/README.sh index accfe4a..d774df5 100755 --- a/README.sh +++ b/README.sh @@ -11,7 +11,8 @@ docker compose up -d producer consumer docker compose up setup # client -docker-compose -f docker/docker-compose.yml exec cli kafka-acls \ +docker compose exec cli kafka-acls \ + --command-config /mnt/admin.properties \ --authorizer-properties zookeeper.connect=zookeeper \ --add \ --allow-principal User:client \ diff --git a/admin.properties b/admin.properties new file mode 100644 index 0000000..b040250 --- /dev/null +++ b/admin.properties @@ -0,0 +1,5 @@ +sasl.mechanism=PLAIN +security.protocol=SASL_PLAINTEXT +sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ + username="broker" \ + password="geheim"; diff --git a/client.properties b/client.properties deleted file mode 100644 index b040250..0000000 --- a/client.properties +++ /dev/null @@ -1,5 +0,0 @@ -sasl.mechanism=PLAIN -security.protocol=SASL_PLAINTEXT -sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ - username="broker" \ - password="geheim"; diff --git a/docker-compose.yml b/docker-compose.yml index e74d367..efdae08 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -159,7 +159,7 @@ services: image: juplo/toolbox command: sleep infinity volumes: - - ./client.properties:/mnt/client.properties:ro + - ./admin.properties:/mnt/admin.properties:ro stop_grace_period: 0s depends_on: - kafka-1 @@ -169,12 +169,11 @@ services: setup: image: juplo/toolbox volumes: - - ./client.properties:/mnt/client.properties:ro + - ./admin.properties:/mnt/admin.properties:ro command: - bash - -c - | - cub kafka-ready -b kafka-1:9092,kafka-2:9092,kafka-3:9092 3 60 > /dev/null 2>&1 || exit 1 if [ -e INITIALIZED ] then echo -n Bereits konfiguriert: @@ -182,19 +181,19 @@ services: kafka-topics --bootstrap-server kafka:9092 --describe --topic test else kafka-topics --bootstrap-server kafka:9092 \ - --command-config /mnt/client.properties \ + --command-config /mnt/admin.properties \ --delete \ --if-exists \ --topic test kafka-topics --bootstrap-server kafka:9092 \ - --command-config /mnt/client.properties \ + --command-config /mnt/admin.properties \ --create \ --topic test \ --partitions 2 \ --replication-factor 3 \ --config min.insync.replicas=2 \ && echo Das Topic \'test\' wurde erfolgreich angelegt: \ - && kafka-topics --bootstrap-server kafka:9092 --command-config /mnt/client.properties --describe --topic test \ + && kafka-topics --bootstrap-server kafka:9092 --command-config /mnt/admin.properties --describe --topic test \ && date > INITIALIZED fi stop_grace_period: 0s