diff options
| author |   varun gudisena <vg411h@att.com> | 2018-02-13 17:41:49 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-02-13 17:41:49 +0000 |
| commit | 3d4e12d9293a7a3ca3cceb03289d11497ccbff38 (patch) | |
| tree | 83842a4c804e6e199ec2b8505d50e6be61febe1b /src/main/java/com/att/nsa/cambria | |
| parent | 7821d96a86b22e9173fa3e582a8e07de12c1474c (diff) | |
| parent | 4403e562936d6029155856a1f3d558b21023fe74 (diff) | |
Merge "sonar critical for error handling"
Diffstat (limited to 'src/main/java/com/att/nsa/cambria')
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java | 2 |
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; |