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 plugins 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 plugins 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: