added local server implementation writing to kafka