Skip to main content
Version: 2.3.3

Socket

Socket source connector

Description​

Used to read data from Socket.

Key features​

Options​

nametyperequireddefault value
hostStringYes
portIntegerYes
common-optionsno-

host [string]​

socket server host

port [integer]​

socket server port

common options​

Source plugin common parameters, please refer to Source 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 {
Socket {
host = "localhost"
port = 9999
}
}

sink {
Console {}
}

  • Start a port listening
nc -l 9999
  • Start a SeaTunnel task

  • Socket Source send test data

~ nc -l 9999
test
hello
flink
spark
  • Console Sink print data
[test]
[hello]
[flink]
[spark]

Changelog​

2.2.0-beta 2022-09-26​

  • Add Socket Source Connector

Next Version​

  • host and port become required (3317)