sonar critical for error handling 21/31421/1
authorDushyant Singh Thakur <dt00503496@techmahindra.com>
Mon, 12 Feb 2018 11:51:39 +0000 (17:21 +0530)
committerDushyant Singh Thakur <dt00503496@techmahindra.com>
Mon, 12 Feb 2018 11:51:39 +0000 (17:21 +0530)
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 <dt00503496@techmahindra.com>
src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java

index 44c74a6..d6bfc83 100644 (file)
@@ -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;