Apache Kafka is a distributed streaming platform that is highly scalable and secure, and it can:

Consume and publish messages/event streams, similar to an enterprise messaging system.
Store the messages for as long as you want.
Process the messages/event streams as they occur.

To connect with Kafka, you need to create a Kafka account and define a Kafka listener or a Kafka target. Kafka messages can be consumed and published by a template, transaction, or process flow.

Creating Kafka Account

Kafka account is used to connect with Kafka Server. While creating Kafka account, you need to define the following properties which are used to connect to Kafka Server.

Click Configure > ACCOUNTS > Kafka.
Click Create Kafka account.
In Create Kafka Account window, do the following:
1. In the Name and Description fields, enter the name and description respectively for the new Kafka account.
2. In the Broker field, enter the URL of the Kafka brokers, foe example, host1:port1,host2:port2.
3. In the Security Protocol field, enter the protocol used to communicate with brokers.
  The supported protocols are PLAINTEXT and SSL.
  For SSL:
  - In case you are using SSL for client authentication, select SSL in the Security Protocol field and then select a Keystore in the Select Keystore field.
  - In case you are using SSL for server authentication, you must import the Kafka server certificate in Adeptia Connect Truststore. To import the certificate, click here.
4. In the Addon Configuration window, enter the Add On Configurations to be used in back end for performing operation on Kafka server (e.g. param1=value,param2=value..).
  
  Here you can use properties which are not listed on this Kafka account creation interface, for example, you may need to use a property called Serializer that converts the data to bytes. You can find the properties available at this location.
5. In the Select Project field, select the project.
6. Click Save.

For more details on creating Kafka Target and Kafka Listener, click here.

You may be interested in...

What is new
Application architecture
Key terms
Install
Usage scenarios

Browser not supported