diff options
| author |   varun gudisena <vg411h@att.com> | 2018-02-13 17:41:15 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-02-13 17:41:15 +0000 |
| commit | 7821d96a86b22e9173fa3e582a8e07de12c1474c (patch) | |
| tree | a0f1d706bee8a36b543c4a60600d4a49bac88806 | |
| parent | d87b973b49648b12dedf86548aa448a2c0a858f8 (diff) | |
| parent | 0259a1401c4882ed924fb72f18c3c0e0c8f1f8b6 (diff) | |
Merge "sonar critical for error handling"
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java index ab8ef26..178d143 100644 --- a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java +++ b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java @@ -400,8 +400,7 @@ public class KafkaConsumerCache { try { curator.delete().guaranteed().forPath(fBaseZkPath + "/" + key); } catch (NoNodeException e) { - log.warn("A consumer was deleted from " + fApiId - + "'s cache, but no Cambria API node had ownership of it in ZooKeeper"); + log.error("Exception at : " + e); } catch (Exception e) { log.debug("Unexpected exception while deleting consumer: " + e.getMessage()); } |