test.transport.mock: pipeInput input-record to mimic old behaviour

[jeremyvdw]

This change broke the previous behavior where the consumer records included timestamp.

This is critical for tests suites asserting windowed results that pushes consumer records to control stream time.