Configuration of the Kafka_GeneralSample Processes

Kafka_GeneralSample

The sample project contains two processes. After Importing the Sample Project, expand the Processes resource to display the processes.

This sample project contains the following two processes:

• SendMessage.bwp
• ReceiveMessage.bwp

SendMessage.bwp

This process demonstrates how to use the plug-ins to send messages through producer using Kafka server. ParseData activity is used to read messages one at a time from the text file so that each line is sent as a separate message.

ReceiveMessage.bwp

This process contains a ReceiveMessage process starter. The ReceiveMessage activity listens for an incoming message event and starts the job execution on receiving the incoming records and writes them to a log.

Activity configuration for the ReceiveMessage.bwp: