socket
Connects to a tcp or unix socket and consumes a continuous stream of messages.
# Config fields, showing default values
input:
label: ""
socket:
network: "" # No default (required)
address: /tmp/benthos.sock # No default (required)
scanner:
lines: {}
Fields
network
A network type to assume (unix|tcp).
Type: string
Options: unix
, tcp
.
address
The address to connect to.
Type: string
# Examples
address: /tmp/benthos.sock
address: 127.0.0.1:6000
scanner
The scanner by which the stream of bytes consumed will be broken out into individual messages. Scanners are useful for processing large sources of data without holding the entirety of it within memory. For example, the csv
scanner allows you to process individual CSV rows without loading the entire CSV file in memory at once.
Type: scanner
Default: {"lines":{}}
Requires version 4.25.0 or newer