Skip to main content
Version: Current

Topic (Sink)

version: Enterprise Mode: Streaming

Description​

Topic Sink allows to write data to the Kafka topic hosted Nussknacker Cloud ("internal topics"). You can use internal Kafka topics to:

  • route data between scenarios
  • send events to a topic via public HTTPS or WebSocket endpoint
  • receive results via HTTP callback or WebSocket subscription

To connect Nussknacker to your own Kafka cluster, see Kafka Integrations.

Use the Topic link (top right of the Designer window) to create an internal topic; read this document to learn how to create an internal topic.

Parameters and configuration​

NameDescription
Topic nameKafka topic to write to
VersionSchema version

Advanced parameters​

NameDescription
Event timeExpression which evaluates to the time when the event was created. For Kafka sources, creation timestamp is available in the Kafka event and can be accessed in SpEL as #inputMeta.timestamp. Check here
Max out-of-ordernessThe maximum amount of time an element is allowed to be late before being ignored when computing the result for time-based stream transformations: aggregates in time windows and joins. To read more about this mechanism see Flink documentation
IdlenessThe time period after which partition is marked as idle if no events are received from it. To read more about this mechanism see Flink documentation.