Skip to main content
Version: 2.3.0-beta

Console

Console sink connector

Description​

Output data to standard terminal or Flink taskManager, which is often used for debugging and easy to observe the data.

tip

Engine Supported and plugin name

  • Spark: Console
  • Flink: Console

Options​

nametyperequireddefault value
limitnumberno100
serializerstringnoplain
common-optionsstringno-

limit [number]​

Limit the number of rows to be output, the legal range is [-1, 2147483647] , -1 means that the output is up to 2147483647 rows

serializer [string]​

The format of serialization when outputting. Available serializers include: json , plain

common options [string]​

Sink plugin common parameters, please refer to Sink Plugin for details

Examples​

console {
limit = 10,
serializer = "json"
}

Output 10 rows of data in Json format