| # Licensed to the Apache Software Foundation (ASF) under one |
| # or more contributor license agreements. See the NOTICE file |
| # distributed with this work for additional information |
| # regarding copyright ownership. The ASF licenses this file |
| # to you under the Apache License, Version 2.0 (the |
| # "License"); you may not use this file except in compliance |
| # with the License. You may obtain a copy of the License at |
| # |
| # http://www.apache.org/licenses/LICENSE-2.0 |
| # |
| # Unless required by applicable law or agreed to in writing, |
| # software distributed under the License is distributed on an |
| # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| # KIND, either express or implied. See the License for the |
| # specific language governing permissions and limitations |
| # under the License. |
| --- |
| services: |
| broker: |
| image: confluentinc/cp-kafka:7.3.0 |
| labels: |
| breeze.description: "Integration required for Kafka hooks." |
| hostname: broker |
| container_name: broker |
| ports: |
| - "9092:9092" |
| - "9101:9101" |
| environment: |
| KAFKA_BROKER_ID: 1 |
| KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: > |
| CONTROLLER:PLAINTEXT, |
| PLAINTEXT:PLAINTEXT, |
| PLAINTEXT_HOST:PLAINTEXT |
| KAFKA_ADVERTISED_LISTENERS: > |
| PLAINTEXT://broker:29092, |
| PLAINTEXT_HOST://localhost:9092 |
| KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1 |
| KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0 |
| KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1 |
| KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1 |
| KAFKA_JMX_PORT: 9101 |
| KAFKA_JMX_HOSTNAME: localhost |
| KAFKA_PROCESS_ROLES: 'broker,controller' |
| KAFKA_NODE_ID: 1 |
| KAFKA_CONTROLLER_QUORUM_VOTERS: '1@broker:29093' |
| KAFKA_LISTENERS: > |
| PLAINTEXT://broker:29092, |
| CONTROLLER://broker:29093, |
| PLAINTEXT_HOST://0.0.0.0:9092 |
| KAFKA_INTER_BROKER_LISTENER_NAME: 'PLAINTEXT' |
| KAFKA_CONTROLLER_LISTENER_NAMES: 'CONTROLLER' |
| KAFKA_LOG_DIRS: '/tmp/kraft-combined-logs' |
| volumes: |
| - ./kafka/update_run.sh:/tmp/update_run.sh |
| command: > |
| bash -c 'if [ ! -f /tmp/update_run.sh ]; |
| then echo "ERROR: update_run.sh not mounted?" |
| && exit 1 ; else /tmp/update_run.sh && /etc/confluent/docker/run ; fi' |
| |
| airflow: |
| environment: |
| - INTEGRATION_KAFKA=true |
| depends_on: |
| - broker |