Fixed typo

This commit is contained in:
Petar Bozin 2017-04-21 19:45:43 +00:00
parent 50e8320bc9
commit eaab54192d

View File

@ -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())