From d9c9b8a3b460fd1674b3f0989a6481fa25cb97a3 Mon Sep 17 00:00:00 2001 From: christinaausley <84338309+christinaausley@users.noreply.github.com> Date: Mon, 10 Jun 2024 15:01:39 -0400 Subject: [PATCH] add 3913 to next (#3914) --- .../connectors/out-of-the-box-connectors/kafka.md | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) 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