This repository reflects the current state of the Kotlin/Beam/Kafka app as written live on YouTube: https://www.youtube.com/watch?v=Ycim03b24CU&list=PLWWyzc5ehM91WKA467swlSgR1r_2m5LMJ
You can find a quick getting started guide here: https://www.codingblocks.net/programming/getting-started-with-apache-beam-and-kotlin/
Currently this repository is currently reading data from Kafka topic, currently hard-coded to localhost:9092 and "raw-sightings."
You can get this environment set up quickly by cloning the following repository and following it's instructions: https://github.com/codingblocks/tracking-ufo-presentation