​
Infrastructure prerequisites

Before proceeding with the setup, ensure that the following components have been set up:
  • Redis
  • Kafka

​
Configuration

​
Configuring Kafka

Set the following Kafka-related configurations using environment variables:
  • SPRING_KAFKA_BOOTSTRAPSERVERS - the address of the Kafka server, it should be in the format “host:port”

​
Groupd IDs

The configuration parameters “KAFKA_CONSUMER_GROUPID_*” are used to set the consumer group name for Kafka consumers that consume messages from topics. Consumer groups in Kafka allow for parallel message processing by distributing the workload among multiple consumer instances. By configuring the consumer group ID, you can specify the logical grouping of consumers that work together to process messages from the same topic, enabling scalable and fault-tolerant message consumption in your Kafka application.
Configuration ParameterDefault valueDescription
KAFKA_CONSUMER_GROUPID_PROCESSENGINECOMMANDS_MESSAGEengine-commands-messageConsumer group ID for processing engine commands messages
KAFKA_CONSUMER_GROUPID_PROCESSENGINECOMMANDS_DISCONNECTengine-commands-disconnectConsumer group ID for processing engine commands disconnect messages
KAFKA_CONSUMER_GROUPID_PROCESSENGINECOMMANDS_CONNECTengine-commands-connectConsumer group ID for processing engine commands connect messages
KAFKA_CONSUMER_GROUPID_PROCESS_TASKCOMMANDS_MESSAGEtask-commands-messageConsumer group ID for processing task commands
KAFKA_CONSUMER_GROUPID_PROCESSVERSIONCOMMANDS_MESSAGEprocess-version-commands-messageConsumer group ID for processing process version commands messages
KAFKA_CONSUMER_GROUPID_GENERICCOMMANDSgeneric-commands-messageConsumer group ID for processing generic commands messages
KAFKA_CONSUMER_GROUPID_USERBROADCASTCOMMANDSuser-broadcast-commands-messageConsumer group ID for processing user broadcast commands messages

​
Threads

The configuration parameters “KAFKA_CONSUMER_THREADS_*” are utilized to specify the number of threads assigned to Kafka consumers for processing messages from topics. These parameters allow you to fine-tune the concurrency and parallelism of your Kafka consumer application, enabling efficient and scalable message consumption from Kafka topics.
Configuration ParameterDefault valueDescription
KAFKA_CONSUMER_THREADS_PROCESSENGINECOMMANDS_MESSAGE10Number of threads for processing engine commands messages
KAFKA_CONSUMER_THREADS_PROCESSENGINECOMMANDS_DISCONNECT5Number of threads for processing engine commands disconnect messages
KAFKA_CONSUMER_THREADS_PROCESSENGINECOMMANDS_CONNECT5Number of threads for processing engine commands connect messages
KAFKA_CONSUMER_THREADS_TASKCOMMANDS10Number of threads for task commands
KAFKA_CONSUMER_THREADS_PROCESSVERSIONCOMMANDS10Number of threads for processing process version commands messages
KAFKA_CONSUMER_THREADS_GENERICCOMMANDS10Number of threads for processing generic commands messages
KAFKA_CONSUMER_THREADS_USERBROADCASTCOMMANDS10Number of threads for processing user broadcast commands messages
Configuration ParameterDefault value
KAFKA_TOPIC_EVENTSGATEWAY_PROCESSINSTANCE_IN_MESSAGEai.flowx.dev.eventsgateway.engine.commands.message.v1
KAFKA_TOPIC_EVENTSGATEWAY_PROCESSINSTANCE_IN_DISCONNECTai.flowx.dev.eventsgateway.engine.commands.disconnect.v1
KAFKA_TOPIC_EVENTSGATEWAY_PROCESSINSTANCE_IN_CONNECTai.flowx.dev.eventsgateway.engine.commands.connect.v1
Configuration ParameterDefault value
KAFKA_TOPIC_EVENTSGATEWAY_PROCESSVERSION_IN_MESSAGEai.flowx.dev.eventsgateway.process-version-commands.message.v1
Configuration ParameterDefault value
KAFKA_TOPIC_EVENTSGATEWAY_USERMESSAGES_IN_MESSAGEai.flowx.dev.core.designer.notification.user.v1

​
Configuring authorization & access roles

Set the following environment variables to connect to the identity management platform:
Configuration ParameterDescription
SECURITY_OAUTH2_BASESERVERURLBase URL of the OAuth2 server
SECURITY_OAUTH2_CLIENT_CLIENTIDClient ID for OAuth2 authentication
SECURITY_OAUTH2_CLIENT_CLIENTSECRETClient secret for OAuth2 authentication
SECURITY_OAUTH2_REALMRealm for OAuth2 authentication

​
Redis

The process engine sends the messages to the events-gateway, which is responsible for sending them to Redis.
Configuration ParameterDescription
SPRING_DATA_REDIS_HOSTHostname of the Redis server
SPRING_DATA_REDIS_PASSWORDPassword for Redis server
SPRING_DATA_REDIS_PORTConnect to the Redis server

​
Master replica

The events-gateway can be configured to communicate with Redis using the MASTER_REPLICA replication mode by configuring the following property: spring.data.redis.sentinel.nodes: replica1, replica2, replica3, etc… Correspondent environment variable:
  • SPRING_DATA_REDIS_SENTINEL_NODES
Example
spring.redis.sentinel.nodes=host1:26379,host2:26379,host3:26379
In the above example, the Spring Boot application will connect to three Redis Sentinel nodes: host1:26379, host2:26379, and host3:26379. The property value should be a comma-separated list of host:port pairs, where each pair represents the hostname or IP address and the port number of a Redis Sentinel node.
By default, Redis is standalone, so the configuration with redis-replicas is optional for high load use cases.
In the context of Spring Boot and Redis Sentinel integration, the spring.redis.sentinel.nodes property is used to specify the list of Redis Sentinel nodes that the Spring application should connect to. These nodes are responsible for monitoring and managing Redis instances.

​
Events

This configuration helps manage how event data is stored and accessed in Redis.
Configuration ParameterDefaultDescription
EVENTS_REDIS_FREQUENCYMILLIS200Time interval (in milliseconds) between Redis queries by the events gateway to check for new messages
EVENTS_REDIS_TTLHOURS4Sets the time-to-live for events in Redis to 4 hours

​
Configuring logging

The following environment variables could be set in order to control log levels:
Configuration ParameterDescription
LOGGING_LEVEL_ROOTLogging level for the root Spring Boot microservice logs
LOGGING_LEVEL_APPLogging level for the application-level logs