version: "3"
# ============LICENSE_START=======================================================
# csit-dcaegen2-collectors-hv-ves
# ================================================================================
# Copyright (C) 2018-2019 NOKIA
# ================================================================================
# Licensed 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.
# ============LICENSE_END=========================================================


networks:
  hv-ves-default:
    external:
      name: $CONTAINERS_NETWORK

services:

  #
  # DMaaP Message Router
  #

  zookeeper:
    image: ${ZOOKEEPER_IMAGE_FULL_NAME}
    ports:
      - "2181:2181"
    networks:
      - hv-ves-default

  kafka:
    image: ${KAFKA_IMAGE_FULL_NAME}
    ports:
      - "9092:9092"
      - "9093:9093"
    environment:
      HOST_IP: 127.0.0.1
      KAFKA_BROKER_ID: 0
      ENDPOINT_PORT: 30490
      KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"
      KAFKA_AUTO_CREATE_TOPICS_ENABLE: "true"
      KAFKA_DELETE_TOPIC_ENABLE: "true"

      KAFKA_LISTENERS: "INTERNAL_SASL_PLAINTEXT://0.0.0.0:9092,EXTERNAL_SASL_PLAINTEXT://0.0.0.0:9093"
      KAFKA_ADVERTISED_LISTENERS: "INTERNAL_SASL_PLAINTEXT://:9092,EXTERNAL_SASL_PLAINTEXT://:9093"
      KAFKA_ADVERTISED_HOST_NAME: "kafka"
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: "INTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT,EXTERNAL_SASL_PLAINTEXT:SASL_PLAINTEXT"
      KAFKA_INTER_BROKER_LISTENER_NAME: "INTERNAL_SASL_PLAINTEXT"
      KAFKA_SASL_ENABLED_MECHANISMS: "PLAIN"
      KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: "PLAIN"
      KAFKA_AUTHORIZER_CLASS_NAME: "org.onap.dmaap.kafkaAuthorize.KafkaCustomAuthorizer"

      aaf_locate_url: https://aaf-locate:8095
      KAFKA_LOG_DIRS: /opt/kafka/data
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
      KAFKA_DEFAULT_REPLICATION_FACTOR: 1
      KAFKA_NUM_PARTITIONS: 1
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
    depends_on:
      - zookeeper
    networks:
      - hv-ves-default

  #
  # DCAE HV VES Collector
  #

  hv-ves-collector:
    image: ${DOCKER_REGISTRY}/${HV_VES_COLLECTOR_NAMESPACE}/${HV_VES_GROUP_ID}.${HV_VES_IMAGE}:${HV_VES_VERSION}
    ports:
      - "6060:6060"
      - "6061:6061/tcp"
    command: ["--configuration-file", "/etc/ves-hv/configuration/secure.json"]
    environment:
      - JAVA_OPTS
      - HOSTNAME=${HV_VES_HOSTNAME}
      - CONSUL_HOST
      - CONFIG_BINDING_SERVICE
      - CONFIG_BINDING_SERVICE_SERVICE_PORT
      - CBS_CLIENT_CONFIG_PATH
    healthcheck:
      interval: 10s
      timeout: 5s
      retries: 2
      test: ${HV_VES_HEALTHCHECK_CMD}
    volumes:
      - ./collector/:/etc/ves-hv/
    depends_on:
      - kafka
    networks:
      - hv-ves-default

  unencrypted-hv-ves-collector:
    image: ${DOCKER_REGISTRY}/${HV_VES_COLLECTOR_NAMESPACE}/${HV_VES_GROUP_ID}.${HV_VES_IMAGE}:${HV_VES_VERSION}
    ports:
      - "7060:6060"
      - "7061:6061/tcp"
    command: ["--configuration-file", "/etc/ves-hv/configuration/insecure.json"]
    environment:
      - JAVA_OPTS
      - HOSTNAME=${HV_VES_HOSTNAME}
      - CONSUL_HOST
      - CONFIG_BINDING_SERVICE
      - CONFIG_BINDING_SERVICE_SERVICE_PORT
      - CBS_CLIENT_CONFIG_PATH
    healthcheck:
      interval: 10s
      timeout: 5s
      retries: 2
      test: ${HV_VES_HEALTHCHECK_CMD}
    volumes:
      - ./collector/:/etc/ves-hv/
    depends_on:
      - kafka
    networks:
      - hv-ves-default

  dcae-app-simulator:
    image: ${DOCKER_REGISTRY}/${HV_VES_COLLECTOR_NAMESPACE}/${HV_VES_GROUP_ID}.${DCAE_APP_SIMULATOR_IMAGE}:${HV_VES_VERSION}
    ports:
      - "6063:6063/tcp"
    command: ["--listen-port", "6063", "--kafka-bootstrap-servers", "kafka:9092", "--kafka-topics", "non-existing-topic"]
    healthcheck:
      interval: 10s
      timeout: 5s
      retries: 2
      test: "curl --request GET --fail --silent --show-error localhost:6063/healthcheck"
    depends_on:
      - kafka
    networks:
      - hv-ves-default