Add interface for the producer in KafkaW

Created by: rerpha

This means we can plug in a fake producer for testing. currently the consumer has one so can be used as reference