summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorDushyant Singh Thakur <dt00503496@techmahindra.com>2018-02-08 16:42:28 +0530
committerDushyant Singh Thakur <dt00503496@techmahindra.com>2018-02-08 16:42:28 +0530
commit76238c0d2b0619084e2a6a83c3597fd5f0e0add5 (patch)
treef87fb016c5b22ef14abe9fd9de7a1570914b2380 /src
parent9e7de354f2c957076411f7c0d95af3d4ee44b237 (diff)
sonar critical for errorhandling
Either log or rethrow the exception Sonar Link: https://sonar.onap.org/component_issues?id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr#severities=CRITICAL|assignees=dthakur Location: src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java Line No-142 Change-Id: I704c301b4221c83cb94f6eb60626c8baa04da483 Issue-ID: DMAAP-276 Signed-off-by: Dushyant Singh Thakur <dt00503496@techmahindra.com>
Diffstat (limited to 'src')
-rw-r--r--src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java2
1 files changed, 1 insertions, 1 deletions
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..c0ba42d 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
@@ -140,7 +140,7 @@ public class KafkaConsumer implements Consumer {
};
}
} catch (kafka.consumer.ConsumerTimeoutException x) {
- log.debug(fLogTag + ": ConsumerTimeoutException in Kafka consumer; returning null. ");
+ log.error(fLogTag + ": ConsumerTimeoutException in Kafka consumer; returning null & Exception at nextMessage() : " + x);
} catch (java.lang.IllegalStateException x) {
log.error(fLogTag + ": Illegal state exception in Kafka consumer; dropping stream. " + x.getMessage());
}