summaryrefslogtreecommitdiffstats
path: root/src/main/java/com
diff options
context:
space:
mode:
authorvarun gudisena <vg411h@att.com>2018-02-13 17:41:49 +0000
committerGerrit Code Review <gerrit@onap.org>2018-02-13 17:41:49 +0000
commit3d4e12d9293a7a3ca3cceb03289d11497ccbff38 (patch)
tree83842a4c804e6e199ec2b8505d50e6be61febe1b /src/main/java/com
parent7821d96a86b22e9173fa3e582a8e07de12c1474c (diff)
parent4403e562936d6029155856a1f3d558b21023fe74 (diff)
Merge "sonar critical for error handling"
Diffstat (limited to 'src/main/java/com')
-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 c0ba42d..692f093 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.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());
+ log.error(fLogTag + ": Error found next() at : " + x);
}
return null;