Implement Kafka communication with Theodolite Kotlin