Merge "sonar critical for error handling"

diff --cc src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
index c0ba42d,d6bfc83..692f093
--- 1/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
--- 2/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
+++ b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumer.java
@@@ -140,9 -140,9 +140,9 @@@ public class KafkaConsumer implements C
                                };
                        }
                } catch (kafka.consumer.ConsumerTimeoutException x) {
 -                      log.debug(fLogTag + ": ConsumerTimeoutException in Kafka consumer; returning null. ");
 +                      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;