fixing kafka integration