diff --git a/docs/components/connectors/out-of-the-box-connectors/kafka.md b/docs/components/connectors/out-of-the-box-connectors/kafka.md index 4603ea614a..8271708609 100644 --- a/docs/components/connectors/out-of-the-box-connectors/kafka.md +++ b/docs/components/connectors/out-of-the-box-connectors/kafka.md @@ -270,8 +270,9 @@ This schema defines a structure for a record that includes a name (string), an a ### Activation condition -**Activation condition** is an optional FEEL expression field that allows for the fine-tuning of the Connector activation. -For example, given that a Kafka message (value) contains a field `itemId`, you can set the activation condition to `=(value.itemId = "a4f6j2")`. This way, the connector will only be triggered if the condition is met. Leave this field empty to trigger your Connector for every incoming message. +**Activation condition** is an optional FEEL expression field that allows for the fine-tuning of the Connector activation. This condition filters if the process step triggers when a Kafka message is consumed. + +For example, `=(value.itemId = "a4f6j2")` will only trigger the start event or continue the catch event if the Kafka message has a matching itemId in the incoming message payload. Leave this field empty to trigger your process every time. :::warning By default, **Kafka Consumer Connector** does not commit the offset if the message cannot be processed. This includes cases where the activation condition is not met. @@ -306,6 +307,8 @@ For example, given that your correlation key is defined with `myCorrelationKey` - **Correlation key (process)**: `=myCorrelationKey` - **Correlation key (payload)**: `=value.correlationKey` +You can also use the key of the message to accomplish this in the **Correlation key (payload)** field with `=key`. + Learn more about correlation keys in the [messages guide](../../../concepts/messages). #### Message ID expression