跳到主要内容
版本:2.3.10

Socket

Socket 数据接收器

支持引擎

Spark
Flink
SeaTunnel Zeta

主要特性

描述

用于向Socket Server发送数据。两者都支持流媒体和批处理模式。

例如,如果来自上游的数据是[age:12,name:jared],则发送到Socket服务器的内容如下:{"name":"jared","age":17}

Sink 选项

名称类型是否必传默认值描述
hostStringsocket 服务器主机
portIntegersocket 服务器端口
max_retriesInteger3发送记录的重试失败次数
common-options-源插件常用参数,详见[Source common Options](../sink common-Options.md)

任务示例

这是写入Socket端的随机生成数据

env {
parallelism = 1
job.mode = "STREAMING"
}

source {
FakeSource {
plugin_output = "fake"
schema = {
fields {
name = "string"
age = "int"
}
}
}
}

sink {
Socket {
host = "localhost"
port = 9999
}
}
  • 启动端口侦听
nc -l -v 9999
  • 启动SeaTunnel任务

  • Socket 服务器控制台打印数据

{"name":"jared","age":17}

变更日志

Change Log
ChangeCommitVersion
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d032.3.9
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de7408102.3.4
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd601052.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab166562.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb82.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a112.3.0
[Improve][Connector-V2][Socket] Unified exception for socket source & sink connector (#3511)https://github.com/apache/seatunnel/commit/581292f212.3.0
[feature][connector][socket] Add Socket Connector Option Rules (#3317)https://github.com/apache/seatunnel/commit/b85317bcb2.3.0
[Improve][all] change Log to @Slf4j (#3001)https://github.com/apache/seatunnel/commit/6016100f12.3.0-beta
[DEV][Api] Replace SeaTunnelContext with JobContext and remove singleton pattern (#2706)https://github.com/apache/seatunnel/commit/cbf82f7552.2.0-beta
[#2606]Dependency management split (#2630)https://github.com/apache/seatunnel/commit/fc047be692.2.0-beta
[Feature][Connector-V2] Socket Connector Sink (#2549)https://github.com/apache/seatunnel/commit/94f4600a42.2.0-beta
[api-draft][Optimize] Optimize module name (#2062)https://github.com/apache/seatunnel/commit/f79e3112b2.2.0-beta