Apache Beam | window kafka into text Generator: create a taxi object with information about the taxi and push into kafka producer.
