The FlowX Designer offers various options to configure the Kafka Send Action through the Actions tab at the node level.
PT30S
for a 30-second delay).The Kafka Send Action type is always Automatic. Typically, Kafka Send Actions automatically trigger when the process reaches this step.
You can add parameters via the Custom option or import predefined parameters from an integration.
For detailed information on Integrations management, refer to this link.
You can use dynamic topic names for Kafka Send and Kafka Receive actions in FlowX processes by leveraging Configuration Parameters. This enables flexibility when working with Kafka topics across different environments or use cases.
Steps to Create Dynamic Kafka Topics:
Define Configuration Parameters for Kafka Topics
Navigate to Projects β Your Project β Configuration Parameters in FlowX Designer.
Add or update configuration keys for Kafka topics.
Example:
kafka_send_2
ai.flowx.plugin.document.trigger
kafka_receive
ai.flowx.engine.receive.plugin.document
This allows referencing these parameters dynamically in your Kafka actions.
Use Configuration Parameters in Kafka Send Action
Open the process where you want to configure the Kafka Send Action.
Go to Node Config > Actions.
Select Kafka Send Action as the action type.
Under Parameters, locate the Topics field.
Use a dynamic reference to concatenate a parameter with another value:
${kafka_send_2}.${topic2}
Here:
${kafka_send_2}
dynamically pulls the value from Configuration Parameters.${topic2}
can be another dynamic input set within the process.Configure the Kafka Message Payload
Define the JSON structure for the message payload.
Ensure that all required fields align with the expected schema of the consuming system.
Validate and Test the Configuration
Start the process and check whether messages are correctly sent to the Kafka topic.
If needed, modify the configuration parameters to change the topic dynamically.
The Kafka Send action serves as a versatile tool that facilitates seamless communication across various systems and plugins, enabling efficient data transfer, robust document management, notifications, and process initiation.
This action finds application in numerous scenarios while configuring processes:
The Kafka Send action stands as a versatile facilitator, enabling smooth operations in communication, document management, notifications, and process initiation across diverse systems and plugins.