Socket Source () eads streaming data from a TCP/IP socket connection.
It continuously listens to a server socket and ingests incoming data as records, making it suitable for real-time data pipelines.

Parameters of Socket Source

• Host/IP
  Host name or IP address of the server socket
  Example: localhost, 192.168.1.10
• Port Number
  Port number on which the server socket is listening
  Example: 9999
• Delimiter
  Delimiter used to separate incoming strings into records
  Common values:
  • \n (newline)
  • | (pipe)
  • , (comma)
• Max Retry
  Maximum number of retry attempts to reconnect to the server socket
  Used when the connection is interrupted or the server is temporarily unavailable

Supported Engines

Map Reduce	Spark 1.x RDD	Spark 2.x RDD	Spark 2.x Dataset	Apache Beam 2.29.0 Batch	Apache Beam 2.29.0 Streaming	Apache Flink 1.12.0 Batch	Apache Flink 1.12.0 Streaming	Apache Tez 0.9.1	PySpark