Merge pull request #31 from keyko-io/issue/notnull_values_in_flat

Issue/notnull values in flat

pom.xml

@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>io.keyko.monitoring</groupId>
   <artifactId>web3-event-streamer</artifactId>
-  <version>0.2.8</version>
+  <version>0.2.9</version>
   <name>Web3 Monitoring Event Streamer</name>
   <url>https://github.com/keyko-io/web3-event-streamer</url>
   <inceptionYear>2019</inceptionYear>

src/main/java/io/keyko/monitoring/preprocessing/Transformations.java

@@ -268,6 +268,7 @@ public static KStream<String, FlatEventBlockRecord> flatEventBlockRecord(KStream
       flatEventBlockRecord.setNodeName(eventBlock.getEvent().getNodeName());
       flatEventBlockRecord.setRetries(eventBlock.getEvent().getRetries());
       flatEventBlockRecord.setStatus(getEventStatus(eventBlock.getEvent().getStatus()));
+      flatEventBlockRecord.setTransactionHash(eventBlock.getEvent().getTransactionHash());
       flatEventBlockRecord.setTimestamp(eventBlock.getBlock().getTimestamp());
 
       List<Object> indexedParameteres = eventBlock.getEvent().getIndexedParameters();

src/main/resources/log4j.properties

@@ -1,4 +1,4 @@
-log4j.rootLogger=DEBUG, stdout, file
+log4j.rootLogger=INFO, stdout, file
 
 log4j.appender.stdout=org.apache.log4j.ConsoleAppender
 log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
@@ -9,8 +9,8 @@ log4j.appender.file.DatePattern=yyyy-MM-dd
 log4j.appender.file.encoding=UTF-8
 log4j.appender.file.append=true
 log4j.appender.file.file=./celo-stremer.log
-log4j.appender.file.threshold=DEBUG
+log4j.appender.file.threshold=INFO
 log4j.appender.file.layout=org.apache.log4j.PatternLayout
 log4j.appender.file.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n
 
-log4j.logger.org.apache.kafka.clients.consumer.ConsumerConfig=DEBUG
+log4j.logger.org.apache.kafka.clients.consumer.ConsumerConfig=INFO