Sample producer to a Kafka cluster

producer.scala

//Given an incoming message to train a Streaming Machine Learning Model
val signaturesToTrainModelsOn = 1 to max
val trainTopic = "signatures"

signaturesToTrainModelsOn.foreach { n => 
   streams.send(new ProducerRecord(trainTopic, "sigs", s"$n"))
}

//Given an incoming message to predict
val signaturesToPredictOn = maths.random()
val testTopic = "predictionSignatures"

signaturesToPredictOn.foreach { sig =>
   streams.send(new ProducerRecord(testTopic, "testsigs", s"$sig"))
}