Kafka Connector Guide

Back Next

Kafka Process Creation

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.

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:

https://knowledge.informatica.com/s/article/DOC-18233

Kafka Connections and Processes

Download Guide

Watch

Comments

Cloud Application Integration Homepage

0 COMMENTS

We’d like to hear from you! Log in to comment.

Dave Hofer - August 28, 2023

The Kafka consumer process is not a process. It's 2 bulleted items that alone are baffling. Why not go into actual detail about exactly how the process works?

Informatica Documentation Team - August 30, 2023

Hi Dave,

We’re working to address your comments and will get back to you.

Thanks,

Informatica Documentation team

Rename Saved Search

Table of Contents

Kafka Connector Guide

Kafka Connector Guide

Kafka Process Creation

Kafka Process Creation

Kafka consumer process

Kafka producer process