Moved all kafka test to kafka_test file
All these are integration tests that needs a kafka instance to be performed. The old integration_test file has been removed for more clarity.
Debug code from main function file has been removed and transformed to an actual publish/consume test.