Puts works (the producer.send is being called). Need to update the test to ensure that the topic is created
before the test starts. Can copy it out from the KafkaSourceTest.

From debugging I can see the take also works, but as of now no way to test for correctness as topic is not there yet.