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 the producer using Kafka server. JavaInvoke activity is used to invoke the Java class method. It returns the message, which is 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 messages 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: