This section provides configuration steps for enabling process instance indexing using the Kafka transport strategy.
flowx.use-elasticsearch
is being replaced. However, to ensure backward compatibility, it will still be preserved in the configuration. Below is an example of how to configure it:
flowx.indexing.enabled
property determines whether indexing with Elasticsearch is enabled. When set to false or missing, no indexing will be performed for any entities defined below. When set to true, indexing with Elasticsearch is enabled.
flowx.indexing.processInstance.indexing-type
property defines the indexing strategy for process instances. It can have one of the following values:
FLOWX_INDEXING_ENABLED
: Set this parameter to true
to enable indexing with Elastisearch for the entire application.Variable Name | Enabled | Description |
---|---|---|
FLOWX_INDEXING_ENABLED | true | Indexing with Elasticsearch for the whole app is enabled |
FLOWX_INDEXING_ENABLED | false | Indexing with Elasticsearch for the whole app is disabled |
FLOWX_INDEXING_PROCESSINSTANCE_INDEXING_TYPE
: Set this parameter to kafka
to use the Kafka transport strategy for indexing process instances.Variable Name | Indexing Type - Values | Definition |
---|---|---|
FLOWX_INDEXING_PROCESSINSTANCE_INDEXING_TYPE | no-indexing | No indexing is performed for process instances |
FLOWX_INDEXING_PROCESSINSTANCE_INDEXING_TYPE | http | Process instances are indexed via HTTP (direct connection from process-engine to Elasticsearch thorugh HTTP calls) |
FLOWX_INDEXING_PROCESSINSTANCE_INDEXING_TYPE | kafka | Process instances are indexed via Kafka (send data to be indexed through a kafka topic - the new strategy for the applied solution) |
FLOWX_INDEXING_PROCESSINSTANCE_INDEX_NAME
: Specify the name of the index used for process instances.Variable Name | Values | Definition |
---|---|---|
FLOWX_INDEXING_PROCESSINSTANCE_INDEXING_INDEX_NAME | process_instance | The name of the index used for storing process instances. It is also part of the search pattern |
FLOWX_INDEXING_PROCESSINSTANCE_SHARDS
: Set the number of shards for the index.Variable Name | Values | Definition |
---|---|---|
FLOWX_INDEXING_PROCESSINSTANCE_SHARDS | 1 | The number of shards for the Elasticsearch index storing process instances |
FLOWX_INDEXING_PROCESSINSTANCE_REPLICAS
: Set the number of replicas for the index.Variable Name | Values | Definition |
---|---|---|
FLOWX_INDEXING_PROCESSINSTANCE_REPLICAS | 1 | The number of replicas for the Elasticsearch index storing process instances |
flowx.indexing.processInstance.index-name
${kafka.topic.process.index.out}
${kafka.topic.naming.prefix}.core.index.process${kafka.topic.naming.suffix}
Default parameter (env var) | Default FLOWX.AI value (can be overwritten) |
---|---|
KAFKA_TOPIC_PROCESS_INDEX_OUT | ai.flowx.dev.core.index.process.v1 |
indexLastUpdatedTime
is new and will be populated for the kafka-connect strategy. This will tell the timestamp when the last operation was done on the object in the index.ßflowx.indexing.processInstance.index-name
config. Here’s an example of the index template: