File tree 1 file changed +79
-0
lines changed
docs/zh/connector-v2/sink
1 file changed +79
-0
lines changed Original file line number Diff line number Diff line change
1
+ # Socket
2
+
3
+ > Socket 数据接收器
4
+
5
+ ## 支持引擎
6
+
7
+ > Spark<br />
8
+ > Flink<br />
9
+ > SeaTunnel Zeta<br />
10
+
11
+ ## 主要特性
12
+
13
+ - [ ] [ exactly-once] ( ../../concept/connector-v2-features.md )
14
+
15
+ ## 描述
16
+
17
+ 用于向Socket Server发送数据。两者都支持流媒体和批处理模式。
18
+
19
+ > 例如,如果来自上游的数据是[ ` age:12,name:jared ` ] ,则发送到Socket服务器的内容如下:` {"name":"jared","age":17} `
20
+
21
+ ## Sink 选项
22
+
23
+ | 名称 | 类型 | 是否必传 | 默认值 | 描述 |
24
+ | ----------------| ---------| ----------| ---------| -----------------------------------------------------------------------------------------------------------------|
25
+ | host | String | 是 | | socket 服务器主机 |
26
+ | port | Integer | 是 | | socket 服务器端口 |
27
+ | max_retries | Integer | 否 | 3 | 发送记录的重试失败次数 |
28
+ | common-options | | 否 | - | 源插件常用参数,详见[ Source common Options] (../sink common-Options.md) |
29
+
30
+ ## 任务示例
31
+
32
+ > 这是写入Socket端的随机生成数据
33
+
34
+ ``` hocon
35
+ env {
36
+ parallelism = 1
37
+ job.mode = "STREAMING"
38
+ }
39
+
40
+ source {
41
+ FakeSource {
42
+ plugin_output = "fake"
43
+ schema = {
44
+ fields {
45
+ name = "string"
46
+ age = "int"
47
+ }
48
+ }
49
+ }
50
+ }
51
+
52
+ sink {
53
+ Socket {
54
+ host = "localhost"
55
+ port = 9999
56
+ }
57
+ }
58
+ ```
59
+
60
+ * 启动端口侦听
61
+
62
+ ``` shell
63
+ nc -l -v 9999
64
+ ```
65
+
66
+ * 启动SeaTunnel任务
67
+
68
+ * Socket 服务器控制台打印数据
69
+
70
+ ``` text
71
+ {"name":"jared","age":17}
72
+ ```
73
+
74
+ ## 更改日志
75
+
76
+ ### 2.2.0-beta 2022-09-26
77
+
78
+ - 添加Socket 数据接收器
79
+
You can’t perform that action at this time.
0 commit comments