Add KafkaIO Integration Tests

It is a good idea to have ITs for KafkaIO.
There are two possible issues:
1. The tests should probably invert the pattern to be readThenWrite given that Unbounded IOs block on Read and ...
2. Until we have a way to do PAsserts on Unbounded sources we can rely on withMaxNumRecords to ensure this test ends.