Added Unit & Integration tests for Kafka module