Skip to content

Commit

Permalink
Merge pull request #18 from keyko-io/feature/lowerCase-in-timeseries-…
Browse files Browse the repository at this point in the history
…topics

Change to lowerCase the ts in the timeseries topics and upgrade schem…
  • Loading branch information
Enrique Ruiz authored Feb 26, 2020
2 parents 25f6398 + ad706af commit 1dc2d57
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>io.keyko.monitoring</groupId>
<artifactId>web3-event-streamer</artifactId>
<version>0.1.4</version>
<version>0.1.5</version>
<name>Web3 Monitoring Event Streamer</name>
<url>https://github.com/keyko-io/web3-event-streamer</url>
<inceptionYear>2019</inceptionYear>
Expand All @@ -20,7 +20,7 @@
<org.json.version>20190722</org.json.version>
<typesafe.config.version>1.4.0</typesafe.config.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<keyko.schemas.version>0.2.4</keyko.schemas.version>
<keyko.schemas.version>0.2.5</keyko.schemas.version>
<junit.version>4.4</junit.version>
</properties>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public static void splitByView(KStream<String, ViewBlockRecord> views) {

public static void splitByTimeSeries(KStream<String, TimeSeriesRecord> ts, String suffix) {
ts.to((key, value, recordContext) ->
"w3m-".concat(value.getContractName().toLowerCase()).concat("-").concat(value.getMethodName().toLowerCase()).concat("_TS").concat(suffix),
"w3m-".concat(value.getContractName().toLowerCase()).concat("-").concat(value.getMethodName().toLowerCase()).concat("_ts").concat(suffix),
Produced.with(Serdes.String(), Web3MonitoringSerdes.getTimeSerieserde())
);
}
Expand Down

0 comments on commit 1dc2d57

Please sign in to comment.