Skip to main content
Version: 2.13.0

Scheduler setup guide

The service is available as a docker image.

It has the following dependencies:

  • a mongodb database
  • needs to be able to connect to the Kafka instance used by the engine

The service comes with most of the needed configuration properties filled in, but there are a few that need to be set up using some custom environment variables.

Dependencies

Mongo database

Basic Mongo configuration - helm values.yaml

scheduler-mdb:
existingSecret: {{secretName}}
mongodbDatabase: {{SchedulerDatabaseName}}
mongodbUsername: {{SchedulerDatabaseUser}}
persistence:
enabled: true
mountPath: /bitnami/mongodb
size: 4Gi
replicaSet:
enabled: true
name: rs0
pdb:
enabled: true
minAvailable:
arbiter: 1
secondary: 1
replicas:
arbiter: 1
secondary: 1
useHostnames: true
serviceAccount:
create: false
usePassword: true
danger

This service needs to connect to a Mongo database that has replicas, in order to work correctly.

Configuration

MongoDB configuration

The MongoDB database is used to persist the scheduled messages until they are sent back. The following configurations need to be set using environment variables:

SPRING_DATA_MONGODB_URI - the uri for the mongodb database

Kafka configuration

The following Kafka related configurations can be set by using environment variables:

SPRING_KAFKA_BOOTSTRAP_SERVERS - address of the Kafka server

SPRING_KAFKA_CONSUMER_GROUP_ID - group of consumers

KAFKA_CONSUMER_THREADS - the number of Kafka consumer threads

KAFKA_AUTH_EXCEPTION_RETRY_INTERVAL - the interval between retries after AuthorizationException is thrown by KafkaConsumer

Each action available in the service corresponds to a Kafka event. A separate Kafka topic must be configured for each use-case.

caution

Make sure the topics configured for this service don't follow the engine pattern.

Logging

The following environment variables could be set in order to control log levels:

LOGGING_LEVEL_ROOT - root spring boot microservice logs

LOGGING_LEVEL_APP - app level logs


Was this page helpful?