diff --git a/pom.xml b/pom.xml index 22be445..38ee300 100644 --- a/pom.xml +++ b/pom.xml @@ -3,7 +3,7 @@ 4.0.0 io.keyko.monitoring web3-event-streamer - 0.2.8 + 0.2.9 Web3 Monitoring Event Streamer https://github.com/keyko-io/web3-event-streamer 2019 diff --git a/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java b/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java index 3188547..79e045c 100644 --- a/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java +++ b/src/main/java/io/keyko/monitoring/preprocessing/Transformations.java @@ -268,6 +268,7 @@ public static KStream 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 indexedParameteres = eventBlock.getEvent().getIndexedParameters(); diff --git a/src/main/resources/log4j.properties b/src/main/resources/log4j.properties index e67718a..dc65573 100644 --- 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