Topic (Sink)

Description

You can use Kafka topics hosted in Nussknacker Cloud ("internal topics") for communication between scenarios. Unlike in the case of externally hosted Kafka topics, there is no need to define a Kafka integration to use internally hosted Kafka topics. Go to this document to learn how to create topic.

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

Parameters and configuration

Name	Description
Topic name	Kafka topic to write to
Version	Schema version

Advanced parameters

Name	Description
Event time	Expression 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-orderness	The 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
Idleness	The 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.