Kinesis Channel
Amazon Kinesis Data Streams helps in real-time collection and processing of data records. By using the Amazon Kinesis channel, TIBCO BusinessEvents can convert Kinesis data streams to TIBCO BusinessEvents events.
For more information on Amazon Kinesis, see Amazon Kinesis Documentation.
Catalog Functions
Kinesis channel supports sending of simple events using functions like Event.replyEvent(), Event.routeTo(), Event.sendEvent().
Kinesis Channel Serializers
Kinesis channel provides the following serializers to handle payloads:
com.tibco.cep.driver.kinesis.serializer.KinesisJsonSerializer
) serializes and deserializes a TIBCO BusinessEvents event along with its payload into (or from) JSON.
For incoming messages, the KinesisJsonSerializer deserializes the text from the message (as an JSON string) to an event. For outgoing events, the serializer converts the event and its payloads into an JSON string. The KinesisJsonSerializer serializer is useful for processing or sending messages between TIBCO BusinessEvents and external systems.
com.tibco.cep.driver.kinesis.serializer.KinesisXmlSerializer
) serializes and deserializes a TIBCO BusinessEvents event along with its payload into (or from) XML.
For incoming messages, the KinesisXmlSerializer deserializes the text from the message (as an XML string) to an event. For outgoing events, the serializer converts the event and its payloads into an XML string. The KinesisXmlSerializer serializer is useful for processing or sending messages between TIBCO BusinessEvents and external systems.
Kinesis Channel Example
A sample TIBCO BusinessEvents application that uses the Kinesis channel is available under BE_HOME/examples/standard/KinesisChannel.