juplo.de Git - demos/kafka/training/blob - docker/docker-compose.yml

   1 version: '3.2'
   2 services:
   3   zookeeper:
   4     image: confluentinc/cp-zookeeper:7.5.1
   5     environment:
   6       ZOOKEEPER_CLIENT_PORT: 2181
   7     ports:
   8       - 2181:2181
   9     volumes:
  10       - zookeeper-data:/var/lib/zookeeper/data
  11       - zookeeper-log:/var/lib/zookeeper/log
  12
  13   kafka-1:
  14     image: confluentinc/cp-kafka:7.5.1
  15     environment:
  16       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
  17       KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9081
  18       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT
  19       KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-1:9091, DOCKER://kafka-1:9092, LOCALHOST://localhost:9081
  20       KAFKA_BROKER_ID: 1
  21       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
  22       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
  23       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
  24       KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.authorizer.AclAuthorizer
  25       KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: "true"
  26       KAFKA_OPTS:
  27         -javaagent:/usr/share/java/cp-base-new/jmx_prometheus_javaagent-0.18.0.jar=0.0.0.0:80:/etc/jmx-exporter.yml
  28         -Dcom.sun.management.jmxremote=true
  29         -Dcom.sun.management.jmxremote.port=9101
  30         -Dcom.sun.management.jmxremote.authenticate=false
  31       KAFKA_METRIC_REPORTERS: com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
  32       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_BOOTSTRAP_SERVERS: localhost:9092
  33       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SECURITY_PROTOCOL: SASL_PLAINTEXT
  34       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_MECHANISM: PLAIN
  35       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_JAAS_CONFIG: org.apache.kafka.common.security.plain.PlainLoginModule required username="ccreporter" password="ccreporter-secret";
  36       KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
  37       KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
  38         org.apache.kafka.common.security.plain.PlainLoginModule required \
  39         user_schemaregistry="schemaregistry-secret" \
  40         user_connect="connect-secret" \
  41         user_ccreporter="ccreporter-secret" \
  42         user_ui="ui-secret" \
  43         user_client="client-secret";
  44       KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
  45       KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
  46         org.apache.kafka.common.security.plain.PlainLoginModule required \
  47         user_client="client-secret";
  48       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
  49       KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
  50     volumes:
  51       - ./jmx-exporter.yml:/etc/jmx-exporter.yml:ro
  52       - ./cruise-control-metrics-reporter.jar:/usr/share/java/kafka/cruise-control-metrics-reporter.jar:ro
  53       - kafka-1-data:/var/lib/kafka/data
  54     ports:
  55       - 9081:9081
  56     stop_grace_period: 120s
  57     depends_on:
  58       - zookeeper
  59
  60   kafka-2:
  61     image: confluentinc/cp-kafka:7.5.1
  62     environment:
  63       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
  64       KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9082
  65       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT
  66       KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-2:9091, DOCKER://kafka-2:9092, LOCALHOST://localhost:9082
  67       KAFKA_BROKER_ID: 2
  68       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
  69       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
  70       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
  71       KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.authorizer.AclAuthorizer
  72       KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: "true"
  73       KAFKA_OPTS:
  74         -javaagent:/usr/share/java/cp-base-new/jmx_prometheus_javaagent-0.18.0.jar=0.0.0.0:80:/etc/jmx-exporter.yml
  75         -Dcom.sun.management.jmxremote=true
  76         -Dcom.sun.management.jmxremote.port=9101
  77         -Dcom.sun.management.jmxremote.authenticate=false
  78       KAFKA_METRIC_REPORTERS: com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
  79       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_BOOTSTRAP_SERVERS: localhost:9092
  80       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SECURITY_PROTOCOL: SASL_PLAINTEXT
  81       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_MECHANISM: PLAIN
  82       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_JAAS_CONFIG: org.apache.kafka.common.security.plain.PlainLoginModule required username="ccreporter" password="ccreporter-secret";
  83       KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
  84       KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
  85         org.apache.kafka.common.security.plain.PlainLoginModule required \
  86         user_schemaregistry="schemaregistry-secret" \
  87         user_connect="connect-secret" \
  88         user_ccreporter="ccreporter-secret" \
  89         user_ui="ui-secret" \
  90         user_client="client-secret";
  91       KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
  92       KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
  93         org.apache.kafka.common.security.plain.PlainLoginModule required \
  94         user_client="client-secret";
  95       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
  96       KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
  97     volumes:
  98       - ./jmx-exporter.yml:/etc/jmx-exporter.yml:ro
  99       - ./cruise-control-metrics-reporter.jar:/usr/share/java/kafka/cruise-control-metrics-reporter.jar:ro
 100       - kafka-2-data:/var/lib/kafka/data
 101     ports:
 102       - 9092:9082
 103       - 9082:9082
 104     networks:
 105       default:
 106         aliases:
 107           - kafka
 108     stop_grace_period: 120s
 109     depends_on:
 110       - zookeeper
 111
 112   kafka-3:
 113     image: confluentinc/cp-kafka:7.5.1
 114     environment:
 115       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
 116       KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9083
 117       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT
 118       KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-3:9091, DOCKER://kafka-3:9092, LOCALHOST://localhost:9083
 119       KAFKA_BROKER_ID: 3
 120       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
 121       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
 122       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
 123       KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.authorizer.AclAuthorizer
 124       KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: "true"
 125       KAFKA_OPTS:
 126         -javaagent:/usr/share/java/cp-base-new/jmx_prometheus_javaagent-0.18.0.jar=0.0.0.0:80:/etc/jmx-exporter.yml
 127         -Dcom.sun.management.jmxremote=true
 128         -Dcom.sun.management.jmxremote.port=9101
 129         -Dcom.sun.management.jmxremote.authenticate=false
 130       KAFKA_METRIC_REPORTERS: com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
 131       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_BOOTSTRAP_SERVERS: localhost:9092
 132       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SECURITY_PROTOCOL: SASL_PLAINTEXT
 133       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_MECHANISM: PLAIN
 134       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_JAAS_CONFIG: org.apache.kafka.common.security.plain.PlainLoginModule required username="ccreporter" password="ccreporter-secret";
 135       KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
 136       KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
 137         org.apache.kafka.common.security.plain.PlainLoginModule required \
 138         user_schemaregistry="schemaregistry-secret" \
 139         user_connect="connect-secret" \
 140         user_ccreporter="ccreporter-secret" \
 141         user_ui="ui-secret" \
 142         user_client="client-secret";
 143       KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
 144       KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
 145         org.apache.kafka.common.security.plain.PlainLoginModule required \
 146         user_client="client-secret";
 147       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
 148       KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
 149     volumes:
 150       - ./jmx-exporter.yml:/etc/jmx-exporter.yml:ro
 151       - ./cruise-control-metrics-reporter.jar:/usr/share/java/kafka/cruise-control-metrics-reporter.jar:ro
 152       - kafka-3-data:/var/lib/kafka/data
 153     ports:
 154       - 9083:9083
 155     stop_grace_period: 120s
 156     depends_on:
 157       - zookeeper
 158
 159   kafka-4:
 160     image: confluentinc/cp-kafka:7.5.1
 161     environment:
 162       KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
 163       KAFKA_LISTENERS: BROKER://:9091, DOCKER://:9092, LOCALHOST://:9084
 164       KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: BROKER:PLAINTEXT, DOCKER:SASL_PLAINTEXT, LOCALHOST:SASL_PLAINTEXT
 165       KAFKA_ADVERTISED_LISTENERS: BROKER://kafka-4:9091, DOCKER://kafka-4:9092, LOCALHOST://localhost:9084
 166       KAFKA_BROKER_ID: 4
 167       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
 168       KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 3
 169       KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
 170       KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.authorizer.AclAuthorizer
 171       KAFKA_ALLOW_EVERYONE_IF_NO_ACL_FOUND: "true"
 172       KAFKA_OPTS:
 173         -javaagent:/usr/share/java/cp-base-new/jmx_prometheus_javaagent-0.18.0.jar=0.0.0.0:80:/etc/jmx-exporter.yml
 174         -Dcom.sun.management.jmxremote=true
 175         -Dcom.sun.management.jmxremote.port=9101
 176         -Dcom.sun.management.jmxremote.authenticate=false
 177       KAFKA_METRIC_REPORTERS: com.linkedin.kafka.cruisecontrol.metricsreporter.CruiseControlMetricsReporter
 178       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_BOOTSTRAP_SERVERS: localhost:9092
 179       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SECURITY_PROTOCOL: SASL_PLAINTEXT
 180       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_MECHANISM: PLAIN
 181       KAFKA_CRUISE_CONTROL_METRICS_REPORTER_SASL_JAAS_CONFIG: org.apache.kafka.common.security.plain.PlainLoginModule required username="ccreporter" password="ccreporter-secret";
 182       KAFKA_LISTENER_NAME_DOCKER_SASL_ENABLED_MECHANISMS: PLAIN
 183       KAFKA_LISTENER_NAME_DOCKER_PLAIN_SASL_JAAS_CONFIG: |
 184         org.apache.kafka.common.security.plain.PlainLoginModule required \
 185         user_schemaregistry="schemaregistry-secret" \
 186         user_connect="connect-secret" \
 187         user_ccreporter="ccreporter-secret" \
 188         user_ui="ui-secret" \
 189         user_client="client-secret";
 190       KAFKA_LISTENER_NAME_LOCALHOST_SASL_ENABLED_MECHANISMS: PLAIN
 191       KAFKA_LISTENER_NAME_LOCALHOST_PLAIN_SASL_JAAS_CONFIG: |
 192         org.apache.kafka.common.security.plain.PlainLoginModule required \
 193         user_client="client-secret";
 194       KAFKA_INTER_BROKER_LISTENER_NAME: BROKER
 195       KAFKA_SASL_ENABLED_MECHANISMS: PLAIN, SCRAM-SHA-256, SCRAM-SHA-512
 196     volumes:
 197       - ./jmx-exporter.yml:/etc/jmx-exporter.yml:ro
 198       - ./cruise-control-metrics-reporter.jar:/usr/share/java/kafka/cruise-control-metrics-reporter.jar:ro
 199       - kafka-4-data:/var/lib/kafka/data
 200     ports:
 201       - 9084:9084
 202     stop_grace_period: 120s
 203     depends_on:
 204       - zookeeper
 205
 206   cruise-control:
 207     image: juplo/cruise-control
 208     environment:
 209       BOOTSTRAP_SERVERS: kafka-1:9091,kafka-2:9091,kafka-3:9091
 210       ZOOKEEPER_CONNECT: zookeeper:2181/
 211     ports:
 212       - "9090:9090"
 213
 214   schema-registry:
 215     image: confluentinc/cp-schema-registry:7.5.1
 216     environment:
 217       SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: kafka-1:9092,kafka-2:9092,kafka-3:9092
 218       SCHEMA_REGISTRY_HOST_NAME: schema-registry
 219       SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8085
 220       SCHEMA_REGISTRY_LOG4J_ROOT_LOGLEVEL: INFO
 221       SCHEMA_REGISTRY_KAFKASTORE_SECURITY_PROTOCOL: SASL_PLAINTEXT
 222       SCHEMA_REGISTRY_KAFKASTORE_SASL_MECHANISM: PLAIN
 223       SCHEMA_REGISTRY_KAFKASTORE_SASL_JAAS_CONFIG: >
 224         org.apache.kafka.common.security.plain.PlainLoginModule
 225         required
 226         username="schemaregistry"
 227         password="schemaregistry-secret";
 228     ports:
 229       - 8085:8085
 230     depends_on:
 231       - kafka-1
 232       - kafka-2
 233       - kafka-3
 234
 235   connect:
 236     image: confluentinc/cp-kafka-connect:7.5.1
 237     environment:
 238       CONNECT_BOOTSTRAP_SERVERS: kafka-1:9092,kafka-2:9092,kafka-3:9092
 239       CONNECT_REST_PORT: 8083
 240       CONNECT_REST_LISTENERS: http://0.0.0.0:8083
 241       CONNECT_REST_ADVERTISED_HOST_NAME: connect
 242       CONNECT_CONFIG_STORAGE_TOPIC: __connect-config
 243       CONNECT_OFFSET_STORAGE_TOPIC: __connect-offsets
 244       CONNECT_STATUS_STORAGE_TOPIC: __connect-status
 245       CONNECT_GROUP_ID: kafka-connect
 246       CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE: "true"
 247       CONNECT_KEY_CONVERTER: io.confluent.connect.avro.AvroConverter
 248       CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8085
 249       CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE: "true"
 250       CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter
 251       CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8085
 252       CONNECT_INTERNAL_KEY_CONVERTER: org.apache.kafka.connect.json.JsonConverter
 253       CONNECT_INTERNAL_VALUE_CONVERTER: org.apache.kafka.connect.json.JsonConverter
 254       CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR: 1
 255       CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR: 1
 256       CONNECT_STATUS_STORAGE_REPLICATION_FACTOR: 1
 257       CONNECT_PLUGIN_PATH: /usr/share/java/
 258       # Configure the Connect workers to use SASL/PLAIN.
 259       CONNECT_SASL_MECHANISM: PLAIN
 260       CONNECT_SECURITY_PROTOCOL: SASL_PLAINTEXT
 261       # JAAS
 262       CONNECT_SASL_JAAS_CONFIG: >
 263         org.apache.kafka.common.security.plain.PlainLoginModule required
 264         username="connect"
 265         password="connect-secret";
 266       # producer
 267       CONNECT_PRODUCER_SASL_MECHANISM: PLAIN
 268       CONNECT_PRODUCER_SECURITY_PROTOCOL: SASL_PLAINTEXT
 269       CONNECT_PRODUCER_SASL_JAAS_CONFIG: >
 270         org.apache.kafka.common.security.plain.PlainLoginModule required
 271         username="connect"
 272         password="connect-secret";
 273       # consumer
 274       CONNECT_CONSUMER_SASL_MECHANISM: PLAIN
 275       CONNECT_CONSUMER_SECURITY_PROTOCOL: SASL_PLAINTEXT
 276       CONNECT_CONSUMER_SASL_JAAS_CONFIG: >
 277         org.apache.kafka.common.security.plain.PlainLoginModule required
 278         username="connect"
 279         password="connect-secret";
 280
 281     ports:
 282       - 8083:8083
 283     depends_on:
 284       - schema-registry
 285
 286   cli:
 287     image: juplo/toolbox
 288     command: sleep infinity
 289     stop_grace_period: 0s
 290     depends_on:
 291       - kafka-1
 292       - kafka-2
 293       - kafka-3
 294
 295   setup:
 296     image: juplo/toolbox
 297     command:
 298       - bash
 299       - -c
 300       - |
 301         cub kafka-ready -b kafka-1:9091,kafka-2:9091,kafka-3:9091 3 60 > /dev/null 2>&1 || exit 1
 302         if [ -e INITIALIZED ]
 303         then
 304           echo -n Bereits konfiguriert:
 305           cat INITIALIZED
 306           kafka-topics --bootstrap-server kafka:9091 --describe --topic test
 307           kafka-topics --bootstrap-server kafka:9091 --describe --topic __CruiseControlMetrics
 308         else
 309           kafka-topics --bootstrap-server kafka:9091 \
 310                        --delete \
 311                        --if-exists \
 312                        --topic test
 313           kafka-topics --bootstrap-server kafka:9091 \
 314                        --create \
 315                        --topic test \
 316                        --partitions 2 \
 317                        --replication-factor 3 \
 318                        --config min.insync.replicas=2 \
 319           && echo Das Topic \'test\' wurde erfolgreich angelegt: \
 320           && kafka-topics --bootstrap-server kafka:9091 --describe --topic test
 321           kafka-topics --bootstrap-server kafka:9091 \
 322                        --delete \
 323                        --if-exists \
 324                        --topic __CruiseControlMetrics
 325           kafka-topics --bootstrap-server kafka:9091 \
 326                        --create \
 327                        --topic __CruiseControlMetrics \
 328                        --partitions 2 \
 329                        --replication-factor 3 \
 330                        --config min.insync.replicas=2 \
 331           && echo Das Topic \'__CruiseControlMetrics\' wurde erfolgreich angelegt: \
 332           && kafka-topics --bootstrap-server kafka:9091 --describe --topic __CruiseControlMetrics
 333         fi \
 334         && date > INITIALIZED
 335     stop_grace_period: 0s
 336     depends_on:
 337       - cli
 338
 339   zoonavigator:
 340     image: elkozmon/zoonavigator:1.1.2
 341     ports:
 342       - "8000:80"
 343     environment:
 344       HTTP_PORT: 80
 345       CONNECTION_JUPLO_NAME: juplo
 346       CONNECTION_JUPLO_CONN: zookeeper:2181
 347       AUTO_CONNECT_CONNECTION_ID: JUPLO
 348     depends_on:
 349       - zookeeper
 350
 351   akhq:
 352     image: tchiotludo/akhq:0.23.0
 353     ports:
 354       - 8888:8080
 355     environment:
 356       AKHQ_CONFIGURATION: |
 357         akhq:
 358           connections:
 359             docker-kafka-server:
 360               properties:
 361                 bootstrap.servers: "kafka:9092"
 362                 security.protocol: SASL_PLAINTEXT
 363                 sasl.mechanism: PLAIN
 364                 sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="ui" password="ui-secret";
 365               schema-registry:
 366                 url: "http://schema-registry:8085"
 367               connect:
 368                 - name: "connect"
 369                   url: "http://connect:8083"
 370     depends_on:
 371       - kafka-1
 372       - kafka-2
 373       - kafka-3
 374
 375   producer:
 376     image: juplo/endless-stream-spring-producer:1.0-SNAPSHOT
 377     environment:
 378       producer.throttle-ms: 1
 379       spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
 380       spring.kafka.client-id: producer
 381       spring.kafka.template.default-topic: test
 382       spring.kafka.producer.properties.linger.ms: 100
 383       spring.kafka.jaas.enabled: "true"
 384       spring.kafka.properties.security.protocol: SASL_PLAINTEXT
 385       spring.kafka.properties.sasl.mechanism: PLAIN
 386       spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="client-secret";
 387
 388   consumer-1:
 389     image: juplo/spring-consumer:1.0-SNAPSHOT
 390     environment:
 391       spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
 392       spring.kafka.client-id: consumer-1
 393       spring.kafka.jaas.enabled: "true"
 394       spring.kafka.properties.security.protocol: SASL_PLAINTEXT
 395       spring.kafka.properties.sasl.mechanism: PLAIN
 396       spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="client-secret";
 397
 398   consumer-2:
 399     image: juplo/spring-consumer:1.0-SNAPSHOT
 400     environment:
 401       spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
 402       spring.kafka.client-id: consumer-1
 403       spring.kafka.jaas.enabled: "true"
 404       spring.kafka.properties.security.protocol: SASL_PLAINTEXT
 405       spring.kafka.properties.sasl.mechanism: PLAIN
 406       spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="client-secret";
 407
 408   consumer-3:
 409     image: juplo/spring-consumer:1.0-SNAPSHOT
 410     environment:
 411       spring.kafka.bootstrap-servers: kafka-1:9092, kafka-2:9092, kafka-3:9092
 412       spring.kafka.client-id: consumer-1
 413       spring.kafka.jaas.enabled: "true"
 414       spring.kafka.properties.security.protocol: SASL_PLAINTEXT
 415       spring.kafka.properties.sasl.mechanism: PLAIN
 416       spring.kafka.properties.sasl.jaas.config: org.apache.kafka.common.security.plain.PlainLoginModule required username="client" password="client-secret";
 417
 418 volumes:
 419   zookeeper-data:
 420   zookeeper-log:
 421   kafka-1-data:
 422   kafka-2-data:
 423   kafka-3-data:
 424   kafka-4-data: