Socket

Socket sink connector

Key features​

• exactly-once

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 Sink 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 Nexus task

• Socket Server Console print data

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