Socket

Socket sink connector

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}

Key features

• [ ] exactly-once
• [ ] schema projection

Options

name	type	required	default value
host	String	Yes	-
port	Integer	yes	-
max_retries	Integer	No	3

host [string]

socket server host

port [integer]

socket server port

max_retries [integer]

The number of retries to send record failed

Example

simple:

Socket {
        host = "localhost"
        port = 9999
    }

test:

• Configuring the SeaTunnel config file

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

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

transform {
      sql = "select name, age from fake"
}

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}