Skip to main content
Version: 2.2.0-beta

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

host [string]​

socket server host

port [integer]​

socket server port

max_retries [integer]​

The number of retries to send record failed

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}