Kafka integration tests

we shoud avoid hardcoding paths, these should be abstracted into environment.rb