Modified the (Kafka) Producer to simplify unit testing.
Created by: SkyToGround
This relatively simple change is required for doing proper unit tests in the design of the fast sample environment processing that I have selected. See the relevant JIRA ticket (DM-812).