From 4403e562936d6029155856a1f3d558b21023fe74 Mon Sep 17 00:00:00 2001 From: Dushyant Singh Thakur Date: Mon, 12 Feb 2018 17:21:39 +0530 Subject: 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 --- src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'src/main/java/com/att/nsa/cambria/backends') 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; -- cgit 1.2.3-korg