From eaab54192d0b716e188c20a00030da409f150ee2 Mon Sep 17 00:00:00 2001 From: Petar Bozin Date: Fri, 21 Apr 2017 19:45:43 +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 857ff16d7..cfac36ee4 100644 --- a/src/main/scala/code/bankconnectors/KafkaHelper.scala +++ b/src/main/scala/code/bankconnectors/KafkaHelper.scala @@ -50,7 +50,7 @@ class KafkaHelper extends MdcLoggable { def getResponse(reqId: String): json.JValue = { val tempProps = consumerProps - tempProps.put("groupId", UUID.randomUUID.toString) + tempProps.put("group.id", UUID.randomUUID.toString) var consumer = new KafkaConsumer[String, String](tempProps) consumer.subscribe(util.Arrays.asList(responseTopic)) //consumer.seekToBeginning(consumer.assignment())