Fixed typo

This commit is contained in:
Petar Bozin 2017-04-21 22:03:58 +00:00
parent 2096f78199
commit 402708809f

View File

@ -48,7 +48,7 @@ class KafkaHelper extends MdcLoggable {
implicit val formats = DefaultFormats
def getResponse(reqId: String): json.JValue = {
println("RECEIVING...") val consumerProps = new Properties()
println("RECEIVING...")
val tempProps = producerProps
tempProps.put("group.id", UUID.randomUUID.toString)
var consumer = new KafkaConsumer[String, String](tempProps)