Connects to a (tcp/unix) socket and consumes a continuous stream of messages.
# Common config fields, showing default valuesinput:socket:network: unixaddress: /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).
The address to connect to.
# Examplesaddress: /tmp/benthos.sockaddress: 127.0.0.1:6000
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.
The maximum message buffer size. Must exceed the largest message to be consumed.
The delimiter to use to detect the end of each message. If left empty line breaks are used.