summaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
authorDushyant Singh Thakur <dt00503496@techmahindra.com>2018-02-12 17:21:39 +0530
committerDushyant Singh Thakur <dt00503496@techmahindra.com>2018-02-12 17:21:39 +0530
commit4403e562936d6029155856a1f3d558b21023fe74 (patch)
tree67f2b8c364f3a2a382226b66f16685d0f05955b1 /src/main
parentdad864219b2adcf066e3eb6c54a1f1150f900979 (diff)
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>
Diffstat (limited to 'src/main')
-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..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;