From 402708809ff03d1a587aded093abc9368bb47d22 Mon Sep 17 00:00:00 2001 From: Petar Bozin Date: Fri, 21 Apr 2017 22:03:58 +0000 Subject: [PATCH] Fixed typo --- src/main/scala/code/bankconnectors/KafkaHelper.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/scala/code/bankconnectors/KafkaHelper.scala b/src/main/scala/code/bankconnectors/KafkaHelper.scala index 76ce5ee4b..82f27f174 100644 --- a/src/main/scala/code/bankconnectors/KafkaHelper.scala +++ b/src/main/scala/code/bankconnectors/KafkaHelper.scala @@ -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)