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 processes:
- SendMessage.bwp
- ReceiveMessage.bwp
- Send_GetMessages.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:
Send_GetMessages.bwp
This process demonstrates how to use the Kafka Get Messages activity. It consumes published messages from a Kafka topic.
Activity configuration for the Send_GetMessages.bwp:
Copyright © Cloud Software Group, Inc. All rights reserved.
