Connects to a (tcp/unix) socket and consumes a continuous stream of messages.

# Common config fields, showing default values
network: unix
address: /tmp/benthos.sock

If multipart is set to false each line of data is read as a separate message. If multipart is set to true each line is read as a message part, and an empty line indicates the end of a message.

Messages consumed by this input can be processed in parallel, meaning a single instance of this input can utilise any number of threads within a pipeline section of a config.

If the delimiter field is left empty then line feed (\n) is used.



A network type to assume (unix|tcp).

Type: string
Default: "unix"
Options: unix, tcp.


The address to connect to.

Type: string
Default: "/tmp/benthos.sock"

# Examples
address: /tmp/benthos.sock


Whether messages should be consumed as multiple parts. If so, each line is consumed as a message parts and the full message ends with an empty line.

Type: bool
Default: false


The maximum message buffer size. Must exceed the largest message to be consumed.

Type: number
Default: 1000000


The delimiter to use to detect the end of each message. If left empty line breaks are used.

Type: string
Default: ""