Generate Kafka sample messages

ammonite.scala

import $ivy.`io.monix::monix-kafka-1x:1.0.0-RC1` 
import monix.execution.Scheduler.Implicits.{ global => scheduler }
import monix.kafka._
import scala.concurrent.duration._
val producerCfg = KafkaProducerConfig.default.copy(
  bootstrapServers = List("127.0.0.1:9092")
)
val producer = KafkaProducer[String,String](producerCfg, scheduler)
val messages = scheduler.scheduleWithFixedDelay(1.second, 1.second) { producer.send("test", "hello", s"${System.nanoTime}").runAsync }

// messages.cancel will stop producing the messages