Kotlin Spring Boot Kafka producer example

TestProducer.kt

package nl.sourcelabs.kafka.producer

import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.CommandLineRunner
import org.springframework.boot.SpringApplication
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.kafka.core.KafkaTemplate

@SpringBootApplication
class TestProducer : CommandLineRunner {

    private val LOG = LoggerFactory.getLogger(TestProducer::class.java)

    @Autowired
    private lateinit var template: KafkaTemplate<Any, Any>

    @Throws(Exception::class)
    override fun run(vararg args: String) {
        produceMessages(100, "test")
        LOG.info("Messages sent successfully")
    }

    fun produceMessages(number: Int, topicName: String) {
        for (i in 0 until number) {
            template.send(topicName, Integer.toString(i), Integer.toString(i)).also {
                LOG.info("Sending Message #$i")
            }
        }
    }
}

fun main(args: Array<String>) {
    SpringApplication.run(TestProducer::class.java, *args)
}