ReadPipeline creates a pipeline that reads ints from Kafka and asserts that they match a given slice of ints.

WritePipeline creates a pipeline that writes a given slice of ints to Kafka.