+ schema-registry:
+ image: confluentinc/cp-schema-registry:7.5.1
+ environment:
+ SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERS: kafka-1:9092,kafka-2:9092,kafka-3:9092
+ SCHEMA_REGISTRY_HOST_NAME: schema-registry
+ SCHEMA_REGISTRY_LISTENERS: http://0.0.0.0:8085
+ SCHEMA_REGISTRY_LOG4J_ROOT_LOGLEVEL: INFO
+ SCHEMA_REGISTRY_KAFKASTORE_SECURITY_PROTOCOL: SASL_PLAINTEXT
+ SCHEMA_REGISTRY_KAFKASTORE_SASL_MECHANISM: SCRAM-SHA-512
+ SCHEMA_REGISTRY_KAFKASTORE_SASL_JAAS_CONFIG: >
+ org.apache.kafka.common.security.scram.ScramLoginModule required
+ username="schemaregistry"
+ password="schemaregistry-secret";
+ ports:
+ - 8085:8085
+ depends_on:
+ - kafka-1
+ - kafka-2
+ - kafka-3
+
+ connect:
+ image: confluentinc/cp-kafka-connect:7.5.1
+ environment:
+ CONNECT_BOOTSTRAP_SERVERS: kafka-1:9092,kafka-2:9092,kafka-3:9092
+ CONNECT_REST_PORT: 8083
+ CONNECT_REST_LISTENERS: http://0.0.0.0:8083
+ CONNECT_REST_ADVERTISED_HOST_NAME: connect
+ CONNECT_CONFIG_STORAGE_TOPIC: __connect-config
+ CONNECT_OFFSET_STORAGE_TOPIC: __connect-offsets
+ CONNECT_STATUS_STORAGE_TOPIC: __connect-status
+ CONNECT_GROUP_ID: kafka-connect
+ CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE: "true"
+ CONNECT_KEY_CONVERTER: io.confluent.connect.avro.AvroConverter
+ CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8085
+ CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE: "true"
+ CONNECT_VALUE_CONVERTER: io.confluent.connect.avro.AvroConverter
+ CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL: http://schema-registry:8085
+ CONNECT_INTERNAL_KEY_CONVERTER: org.apache.kafka.connect.json.JsonConverter
+ CONNECT_INTERNAL_VALUE_CONVERTER: org.apache.kafka.connect.json.JsonConverter
+ CONNECT_OFFSET_STORAGE_REPLICATION_FACTOR: 1
+ CONNECT_CONFIG_STORAGE_REPLICATION_FACTOR: 1
+ CONNECT_STATUS_STORAGE_REPLICATION_FACTOR: 1
+ CONNECT_PLUGIN_PATH: /usr/share/java/
+ # Configure the Connect workers to use SASL/PLAIN.
+ CONNECT_SASL_MECHANISM: SCRAM-SHA-512
+ CONNECT_SECURITY_PROTOCOL: SASL_PLAINTEXT
+ # JAAS
+ CONNECT_SASL_JAAS_CONFIG: >
+ org.apache.kafka.common.security.scram.ScramLoginModule required
+ username="connect"
+ password="connect-secret";
+ # producer
+ CONNECT_PRODUCER_SASL_MECHANISM: SCRAM-SHA-512
+ CONNECT_PRODUCER_SECURITY_PROTOCOL: SASL_PLAINTEXT
+ CONNECT_PRODUCER_SASL_JAAS_CONFIG: >
+ org.apache.kafka.common.security.scram.ScramLoginModule required
+ username="connect"
+ password="connect-secret";
+ # consumer
+ CONNECT_CONSUMER_SASL_MECHANISM: SCRAM-SHA-512
+ CONNECT_CONSUMER_SECURITY_PROTOCOL: SASL_PLAINTEXT
+ CONNECT_CONSUMER_SASL_JAAS_CONFIG: >
+ org.apache.kafka.common.security.scram.ScramLoginModule required
+ username="connect"
+ password="connect-secret";
+
+ ports:
+ - 8083:8083
+ depends_on:
+ - schema-registry
+
+ cli: