Adding OpenTSDB logging

SeniorDesignGroup5 · Mar 6, 2019 · 16eae2d · 16eae2d
1 parent 2688b54
commit 16eae2d
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/main/scala/com/powerpanel/kso/KafkaInput.scala b/src/main/scala/com/powerpanel/kso/KafkaInput.scala
@@ -23,7 +23,7 @@ class KafkaInput extends Serializable {
         }
         kafkaParams.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
         kafkaParams.put("value.deserializer", "org.apache.kafka.common.serialization.ByteArrayDeserializer");
-	kafkaParams.put("group.id", props.getProperty("kafka.group_id"));
+	      kafkaParams.put("group.id", props.getProperty("kafka.group_id"));
         val messages = KafkaUtils.createDirectStream[String, Array[Byte]](
           ssc,
           LocationStrategies.PreferConsistent,

diff --git a/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala b/src/main/scala/com/powerpanel/kso/OpenTSDBOutput.scala
@@ -15,7 +15,8 @@ import scala.collection.JavaConversions._
 
 class OpenTSDBOutput extends Serializable {
 
-
+  private[this] val logger = Logger.getLogger(getClass().getName());
+
   def putOpentsdb[T](opentsdbIP: String, stream: DStream[DataPackage]) = {
     stream.mapPartitions(partition => {
       var count = 0;
@@ -57,6 +58,8 @@ class OpenTSDBOutput extends Serializable {
           }
           body.concat("]");
 
+          logger.info(body);
+
           var openTSDBUrl = "http://" + opentsdbIP + "/api/put"
           try {
                 val httpClient = new DefaultHttpClient()