diff --git a/src/main/scala/code/bankconnectors/KafkaHelper.scala b/src/main/scala/code/bankconnectors/KafkaHelper.scala
index 4466faf6e..48096c3e3 100644
--- a/src/main/scala/code/bankconnectors/KafkaHelper.scala
+++ b/src/main/scala/code/bankconnectors/KafkaHelper.scala
@@ -51,7 +51,7 @@ class KafkaHelper extends MdcLoggable {
   def getResponse(reqId: String): json.JValue = {
     println("RECEIVING...")
     val response = for {
-      consumerMap <- consumer.poll(100)
+      consumerMap <- tryo{consumer.poll(100)}
       record: ConsumerRecord[String, String]  <- consumerMap
       if record.key == reqId
     } yield