Move Pipe up to the api project, refactor the BinlogConsumerSpec to use
pipes. A bit more work on KafkaSpec.
Cleanup and simplificiation of the Kafka / Avro producer.