The Scheduler is part of the core extensions of the FlowX.AI platform. It can be easily added to your custom FlowX deployment to enhance the core platform capabilities with functionality specific to scheduling messages.
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.