A set of PDI step plugins to produce and consume rows via a socket transport