Socket source connector
Used to read data from Socket.
name | type | required | default value |
---|---|---|---|
host | String | Yes | |
port | Integer | Yes | |
common-options | no | - |
socket server host
socket server port
Source plugin common parameters, please refer to Source Common Options for details
simple:
Socket { host = "localhost" port = 9999 }
test:
env { execution.parallelism = 1 job.mode = "STREAMING" } source { Socket { host = "localhost" port = 9999 } } sink { Console {} }
nc -l 9999
Start a SeaTunnel task
Socket Source send test data
~ nc -l 9999 test hello flink spark
[test] [hello] [flink] [spark]
host
and port
become required (3317)