Socket.md

Socket

Socket source connector

Support Those Engines

Spark
Flink
SeaTunnel Zeta

Key features

• batch
• stream
• exactly-once
• column projection
• parallelism
• support user-defined split

Description

Used to read data from Socket.

Source Options

Name	Type	Required	Default	Description
host	String	Yes		socket server host
port	Integer	Yes		socket server port
common-options		No	-	Source plugin common parameters, please refer to Source Common Options for details

Task Example

Simple:

This is a streaming accept Socket data source Writes to console output

env {
  # You can set flink configuration here
  execution.parallelism = 1
}
Socket {
  host = "localhost"
  port = 9999
}

transform {
  # If you would like to get more information about how to configure seatunnel and see full list of transform plugins,
  # please go to https://seatunnel.apache.org/docs/transform-v2/sql
}

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)