Configuration of the Kafka_CustomSerializer Processes
Kafka_CustomSerializerSample
The sample project contains two processes. After Importing the Sample Project, expand the Processes resource to display the processes.
The src folder contains the PersonProtos.java file which is a google protobuf defined java representation of the .proto file in a proto folder.
This sample project contains the following two processes:
Send.bwp
The Send.bwp process demonstrates how custom serializer is added to the Send activity to serialize the message. On the Advanced tab in the Properties field, a value.serializer property is configured as an additional property. This property lets the Send activity use the class for serializing the message. For example, Google Protocol Buffer is used to serialize the message from a Person objects (defined in the PersonProtos.java file in the src folder) JSON representation to a byte data.
Activity configuration for the Send.bwp:
Receive.bwp
The Receive.bwp process demonstrates how custom deserializer is added to the Receive activity to deserialize the message. On the Advanced tab in the Properties field a value.deserializer property is configured as an additional property. This property lets the Receive activity use a class for deserializing the message. For example, Google Protocol Buffer is used to deserialize the message from a byte data to a Person objects (defined in the PersonProtos.java file in the src folder) JSON representation.
Activity configuration for the Receive.bwp:
