Skip to main content

Kafka Sink

Synopsis​

This operator provides a Kafka topic as a sink for a streaming analytic workflow.

Description​

This is a streaming operator and needs to be placed inside a Streaming Nest or a Streaming Optimization operator. The operator defines the logical functionality and can be used in all streaming analytic workflow for any supported streaming platform (currently Flink and Spark). The actual implementation used depends on the type of connection connected to the Streaming Nest operator in which this operator is placed.

Input​

connection​

The connection to the Kafka Cluster which topic should be sinked.

input stream​

The input of this streaming operation. It needs to receive the output of a preceding streaming operator, to define the flow of data events in the streaming analytic workflow.

Parameters​

Kafka topic​

Kafka topic which is used as a sink.

Record key​

Name of the field to use for record key.