Configuration of the Kafka_CloudSample Processes

Kafka_CloudSample

The sample project contains three processes. Each process has a different function. After Importing the Sample Project, expand the Processes resource to display the processes.

This sample project contains the following three processes:

• KafkaSendMessage.bwp
• SendMessage_ProducerProcess.bwp
• ReceiveMessageProcess.bwp

KafkaSendMessage.bwp

This process demonstrates how to use the plug-ins to send messages through producer using Kafka server. JavaInvoke activity is used to invoke Java class method. It returns message, which will be read by SendMessage activity.

SendMessage_ProducerProcess.bwp

This process demonstrates how to use the plug-ins to send messages through producer using Kafka server. This process uses "While" loop to send message multiple times.

ReceiveMessageProcess.bwp

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

Activity configuration for the ReceiveMessage.bwp: