Using the scheduler
After deploying the scheduler service in your infrastructure, you can start using it to schedule messages that you need to process at a later time. One such example would be to use the scheduler service to expire processes that were started but havenβt been finished.First you need to check the configured kafka topics match the ones configured in the engine deployment.
For example the engine topics
KAFKA_TOPIC_PROCESS_SCHEDULE_OUT_SET
and KAFKA_TOPIC_PROCESS_SCHEDULE_OUT_STOP
must be the same with the ones configured in the scheduler at KAFKA_TOPIC_SCHEDULE_IN_SET
and KAFKA_TOPIC_SCHEDULE_IN_STOP
environment variables.KAFKA_TOPIC_SCHEDULE_IN_SET
):
java.time.Instant
.
At the scheduled time, the payload will be sent back to the response topic defined in the message, like so:
KAFKA_TOPIC_SCHEDULE_IN_STOP
)
applicationName
and applicationId
are used to uniquely identify a scheduled message.
Scheduler setup
Steps needed in order to deploy and set up the service