After you create a Kafka connection, a Kafka consumer, and a Kafka producer, you can use them in a process. The Kafka connection, Kafka consumer process, and the Kafka producer process must run on the same Secure Agent.
Kafka consumer process
Use the following guidelines when you create a Kafka consumer process:
•Select the process binding as event.
•Select the Kafka consumer that you created in the Kafka connection.
Kafka consumers can consume headers sent with Kafka messages. The message headers are displayed in the event input field of the Process View Detail page in Application Integration Console and can be used in a process.
Note: The headers values are converted to string by default. You must ensure that the header uses a basic primitive type such as integer, floating point, or string. Otherwise, you might see random characters.
Kafka producer process
Use the following guidelines when you create a Kafka producer process:
•Add an Assignment step to prepare the Kafka message that you want to write to the topic.
•Add a Service step to select the Kafka producer. In the input field, select the Kafka message that you prepared in the Assignment step.
•If you want to receive a response ID after you run a process, you can configure an output field to receive the Kafka response.
To view a video about reading and writing Kafka messages, and download a sample process, see the following community article: