diff options
Diffstat (limited to 'src/main')
3 files changed, 6 insertions, 6 deletions
diff --git a/src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java b/src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java index 431163e..a7b0598 100644 --- a/src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java +++ b/src/main/java/com/att/nsa/apiServer/metrics/cambria/DMaaPMetricsSender.java @@ -161,9 +161,9 @@ public class DMaaPMetricsSender implements Runnable { o.put("transactionEnabled", false); fCambria.send(fHostname, o.toString()); } catch (JSONException e) { - log.warn("Error posting metrics to Cambria: " + e.getMessage()); + log.error("Error posting metrics to Cambria at send(): " + e); } catch (IOException e) { - log.warn("Error posting metrics to Cambria: " + e.getMessage()); + log.error("Error posting metrics to Cambria at send(): " + e ); } } 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..c0ba42d 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 @@ -140,7 +140,7 @@ public class KafkaConsumer implements Consumer { }; } } 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()); } 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 8cb6f3c..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 @@ -82,7 +82,7 @@ public class KafkaConsumerCache { // the server at least every 30 seconds, timing out after 2 minutes should // be okay. // FIXME: consider allowing the client to specify its expected call rate? - private static final long kDefault_MustTouchEveryMs = 1000 * 60 * 2; + private static final long kDefault_MustTouchEveryMs = (long)1000 * 60 * 2; // check for expirations pretty regularly private static final long kDefault_SweepEverySeconds = 15; @@ -288,9 +288,9 @@ public class KafkaConsumerCache { curatorConsumerCache.close(); log.info("Curator client closed"); } catch (ZkInterruptedException e) { - log.warn("Curator client close interrupted: " + e.getMessage()); + log.error("Curator client close interrupted: " + e); } catch (IOException e) { - log.warn("Error while closing curator PathChildrenCache for KafkaConsumerCache" + e.getMessage()); + log.error("Error while closing curator PathChildrenCache for KafkaConsumerCache" + e); } curatorConsumerCache = null; |