Update log generator to write directly to kafka