Add missed setTransactionHash

keyko-io · Apr 8, 2020 · 84b7b8b · 84b7b8b
1 parent 81f1b03
commit 84b7b8b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 34 deletions.
diff --git a/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java b/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java
@@ -268,39 +268,9 @@ 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());
 
-
-      flatEventBlockRecord.setIndexedParamValue0("");
-      flatEventBlockRecord.setIndexedParamValue1("");
-      flatEventBlockRecord.setIndexedParamValue2("");
-      flatEventBlockRecord.setIndexedParamValue3("");
-      flatEventBlockRecord.setIndexedParamName0("");
-      flatEventBlockRecord.setIndexedParamName1("");
-      flatEventBlockRecord.setIndexedParamName2("");
-      flatEventBlockRecord.setIndexedParamName3("");
-      flatEventBlockRecord.setIndexedParamType0("");
-      flatEventBlockRecord.setIndexedParamType1("");
-      flatEventBlockRecord.setIndexedParamType2("");
-      flatEventBlockRecord.setIndexedParamType3("");
-
-      flatEventBlockRecord.setNonIndexedParamValue0("");
-      flatEventBlockRecord.setNonIndexedParamValue1("");
-      flatEventBlockRecord.setNonIndexedParamValue2("");
-      flatEventBlockRecord.setNonIndexedParamValue3("");
-      flatEventBlockRecord.setNonIndexedParamValue4("");
-      flatEventBlockRecord.setNonIndexedParamName0("");
-      flatEventBlockRecord.setNonIndexedParamName1("");
-      flatEventBlockRecord.setNonIndexedParamName2("");
-      flatEventBlockRecord.setNonIndexedParamName3("");
-      flatEventBlockRecord.setNonIndexedParamName4("");
-      flatEventBlockRecord.setNonIndexedParamType0("");
-      flatEventBlockRecord.setNonIndexedParamType1("");
-      flatEventBlockRecord.setNonIndexedParamType2("");
-      flatEventBlockRecord.setNonIndexedParamType3("");
-      flatEventBlockRecord.setNonIndexedParamType4("");
-
-
       List<Object> indexedParameteres = eventBlock.getEvent().getIndexedParameters();
       List<Object> nonIndexedParameteres = eventBlock.getEvent().getNonIndexedParameters();
 

diff --git a/src/main/resources/log4j.properties b/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