diff options
| -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 5f38443..8cb6f3c 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()); } |