跳到主要内容
版本:2.3.0

Socket

Socket sink connector

Description

Used to send data to Socket Server. Both support streaming and batch mode.

For example, if the data from upstream is [age: 12, name: jared], the content send to socket server is the following: {"name":"jared","age":17}

Key features

Options

nametyperequireddefault value
hostStringYes
portIntegeryes
max_retriesIntegerNo3
common-optionsno-

host [string]

socket server host

port [integer]

socket server port

max_retries [integer]

The number of retries to send record failed

common options

Sink plugin common parameters, please refer to Sink Common Options for details

Example

simple:

Socket {
host = "localhost"
port = 9999
}

test:

  • Configuring the SeaTunnel config file
env {
execution.parallelism = 1
job.mode = "STREAMING"
}

source {
FakeSource {
result_table_name = "fake"
schema = {
fields {
name = "string"
age = "int"
}
}
}
}

transform {
sql = "select name, age from fake"
}

sink {
Socket {
host = "localhost"
port = 9999
}
}

  • Start a port listening
nc -l -v 9999
  • Start a SeaTunnel task
  • Socket Server Console print data
{"name":"jared","age":17}

Changelog

2.2.0-beta 2022-09-26

  • Add Socket Sink Connector