echo "Starting Kafka in Zookeeper-Mode..."
docker compose up setup
-echo "Setting up ACLs for the consumer and the producer..."
-# client
+echo "Setting up ACLs for the producer..."
docker compose exec cli kafka-acls \
--command-config /mnt/admin.properties \
--bootstrap-server kafka:9092 \
--add \
- --allow-principal User:client \
+ --allow-principal User:producer \
--topic test \
- --consumer --group=my-group \
--producer
docker compose exec cli kafka-acls \
--command-config /mnt/admin.properties \
--bootstrap-server kafka:9092 \
--list \
- --user-principal User:client \
+ --user-principal User:producer \
+ --topic test
+
+echo "Setting up ACLs for the consumer..."
+docker compose exec cli kafka-acls \
+ --command-config /mnt/admin.properties \
+ --bootstrap-server kafka:9092 \
+ --add \
+ --allow-principal User:consumer \
+ --topic test \
+ --consumer --group=my-group \
+
+docker compose exec cli kafka-acls \
+ --command-config /mnt/admin.properties \
+ --bootstrap-server kafka:9092 \
+ --list \
+ --user-principal User:consumer \
--group=my-group \
--topic test
KAFKA_LISTENER_NAME_BROKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_BROKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN
KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
KAFKA_LOG_RETENTION_CHECK_INTERVAL_MS: 10000
KAFKA_LISTENER_NAME_BROKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_BROKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN
KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
KAFKA_LOG_RETENTION_CHECK_INTERVAL_MS: 10000
KAFKA_LISTENER_NAME_BROKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_BROKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
org.apache.kafka.common.security.plain.PlainLoginModule required \
- user_broker="geheim" \
- user_client="geheim" \
+ user_broker="brokerpw" \
+ user_producer="producerpw" \
+ user_consumer="consumerpw" \
username="broker" \
- password="geheim"; \
+ password="brokerpw"; \
KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN
KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
KAFKA_LOG_RETENTION_CHECK_INTERVAL_MS: 10000
spring.kafka.jaas.enabled: "true"
spring.kafka.properties.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: PLAIN
- spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="geheim";
+ spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="producer" password="producerpw";
juplo.producer.topic: test
consumer:
spring.kafka.jaas.enabled: "true"
spring.kafka.properties.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: PLAIN
- spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="geheim";
+ spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="consumer" password="consumerpw";
spring.kafka.consumer.auto-offset-reset: earliest
logging.level.org.apache.kafka.clients.consumer: INFO
juplo.consumer.topic: test
spring.kafka.jaas.enabled: "true"
spring.kafka.properties.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: PLAIN
- spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="geheim";
+ spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="consumer" password="consumerpw";
spring.kafka.consumer.auto-offset-reset: earliest
logging.level.org.apache.kafka.clients.consumer: INFO
juplo.consumer.topic: test
spring.kafka.jaas.enabled: "true"
spring.kafka.properties.security.protocol: SASL_PLAINTEXT
spring.kafka.properties.sasl.mechanism: PLAIN
- spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="geheim";
+ spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="consumer" password="consumerpw";
spring.kafka.consumer.auto-offset-reset: earliest
logging.level.org.apache.kafka.clients.consumer: INFO
juplo.consumer.topic: test