Read will create a new csv reader per message.

ReadStream will read the string messages.

ErrUnknownType is the error for when we don't know how to conver the message to a []string.

To will convert incoming messages to a csv message output and send downstream.