From: Dushyant Singh Thakur <dt00503496@techmahindra.com>
Date: Mon, 12 Feb 2018 11:51:39 +0000 (+0530)
Subject: sonar critical for error handling
X-Git-Tag: v1.1.1~1^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=4403e562936d6029155856a1f3d558b21023fe74;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

sonar critical for error handling

Either log or rethrow this exception
Sonar Link:
https://sonar.onap.org/project/issues?assignees=dthakur&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&resolved=false
Location:
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
Line No-144

Change-Id: I1076da94ab6d938bc5c0b06fd5f21756385a2b9a
Issue-ID: DMAAP-290
Signed-off-by: Dushyant Singh Thakur <dt00503496@techmahindra.com>
---

diff --git a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
index 44c74a6..d6bfc83 100644
--- a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
+++ b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
@@ -142,7 +142,7 @@ public class KafkaConsumer implements Consumer {
 		} catch (kafka.consumer.ConsumerTimeoutException x) {
 			log.debug(fLogTag + ": ConsumerTimeoutException in Kafka consumer; returning null. ");
 		} catch (java.lang.IllegalStateException x) {
-			log.error(fLogTag + ": Illegal state exception in Kafka consumer; dropping stream. " + x.getMessage());
+			log.error(fLogTag + ": Error found next() at : " + x);
 		}
 
 		return null;