services:
  kafka-connect-salesforce-source:
    build:
      dockerfile: Dockerfile
      context: .
    ports:
      - "8083:8083"
    healthcheck:
        test: ["CMD-SHELL", "curl", "-f", "http://localhost:8083/connectors || exit 1" ]
        interval: 30s
        timeout: 5s
        retries: 5
    environment:
      Environment: "local"
      CONNECT_BOOTSTRAP_SERVERS: "SSL://b-1.dev-managed-kafka-cdc.rk4es0.c11.kafka.us-east-1.amazonaws.com:9094,SSL://b-2.dev-managed-kafka-cdc.rk4es0.c11.kafka.us-east-1.amazonaws.com:9094,SSL://b-3.dev-managed-kafka-cdc.rk4es0.c11.kafka.us-east-1.amazonaws.com:9094"
      SERVICE_NAME: "kafka-connect-sforce-source"
      SECRETS_MANAGER_SF_CREDS: "qaorch_sf_keys"
      KAFKA_TOPICS: "sf_source_test"
      # subscribe to FAN CDC events.
      SF_TOPIC: "/data/Fan__ChangeEvent"
      # specify QUERY_FILE or QUERY directly.
      # SF_SOBJECT_QUERY_FILE: "fan_details.soql"
      SF_SOBJECT_QUERY: "select Id,Email__c,IsDeleted,CreatedDate,LastModifiedDate,Source__c"
      SF_INSTANCE: "https://test.salesforce.com"
      SF_REPLAY_ID: "-1"
      AWS_ACCESS_KEY_ID: ""
      AWS_SECRET_ACCESS_KEY: ""
      AWS_SESSION_TOKEN: ""
      CONNECT_GROUP_UNIQUE_IDENTIFIER: "${USER}_local"
    volumes:
      - .env:/etc/kafka-connect/connector_config.properties