Socket
Socket sink connector
Support Those Enginesâ
Spark
Flink
SeaTunnel Zeta
Key featuresâ
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}
Sink Optionsâ
Name | Type | Required | Default | Description |
---|---|---|---|---|
host | String | Yes | socket server host | |
port | Integer | Yes | socket server port | |
max_retries | Integer | No | 3 | The number of retries to send record failed |
common-options | No | - | Source plugin common parameters, please refer to Source Common Options for details |
Task Exampleâ
This is randomly generated data written to the Socket side
env {
parallelism = 1
job.mode = "STREAMING"
}
source {
FakeSource {
result_table_name = "fake"
schema = {
fields {
name = "string"
age = "int"
}
}
}
}
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