From 977ca62e7fbb35b8529cc4fa89589c20fcfd9f03 Mon Sep 17 00:00:00 2001
From: ben <stu126940@mail.uni-kiel.de>
Date: Wed, 18 Mar 2020 11:40:01 +0100
Subject: [PATCH] get duration_in_minutes as environment variable

---
 uc3-application/Dockerfile                                | 8 +++++---
 uc3-application/build.gradle                              | 2 +-
 .../src/main/java/uc3/application/HistoryService.java     | 5 ++++-
 .../src/main/resources/META-INF/application.properties    | 6 ++++++
 4 files changed, 16 insertions(+), 5 deletions(-)
 create mode 100644 uc3-application/src/main/resources/META-INF/application.properties

diff --git a/uc3-application/Dockerfile b/uc3-application/Dockerfile
index 9b17de3af..c70a24268 100644
--- a/uc3-application/Dockerfile
+++ b/uc3-application/Dockerfile
@@ -1,6 +1,8 @@
 FROM openjdk:11-slim
 
-ADD build/distributions/exp-bigdata19-bridge.tar /
 
-CMD export JAVA_OPTS=-Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL \
-    && /exp-bigdata19-bridge/bin/exp-bigdata19-bridge
\ No newline at end of file
+ADD build/distributions/uc3-application.tar /
+
+
+CMD  JAVA_OPTS="$JAVA_OPTS -Dorg.slf4j.simpleLogger.defaultLogLevel=$LOG_LEVEL" \
+     /uc3-application/bin/uc3-application
\ No newline at end of file
diff --git a/uc3-application/build.gradle b/uc3-application/build.gradle
index 12e597b37..b02792013 100644
--- a/uc3-application/build.gradle
+++ b/uc3-application/build.gradle
@@ -21,7 +21,7 @@ dependencies {
     testCompile 'junit:junit:4.12'
 }
 
-mainClassName = "titan.ccp.kiekerbridge.expbigdata19.ExperimentorBigData"
+mainClassName = "uc3.application.HistoryService"
 
 eclipse {
     classpath {
diff --git a/uc3-application/src/main/java/uc3/application/HistoryService.java b/uc3-application/src/main/java/uc3/application/HistoryService.java
index e8385da58..26c9584d2 100644
--- a/uc3-application/src/main/java/uc3/application/HistoryService.java
+++ b/uc3-application/src/main/java/uc3/application/HistoryService.java
@@ -1,6 +1,7 @@
 package uc3.application;
 
 import java.time.Duration;
+import java.util.Objects;
 import java.util.concurrent.CompletableFuture;
 import org.apache.commons.configuration2.Configuration;
 import org.apache.kafka.streams.KafkaStreams;
@@ -17,6 +18,8 @@ public class HistoryService {
 	private final Configuration config = Configurations.create();
 
 	private final CompletableFuture<Void> stopEvent = new CompletableFuture<>();
+	final int KAFKA_WINDOW_DURATION_MINUTES = Integer
+			.parseInt(Objects.requireNonNullElse(System.getenv("KAFKA_WINDOW_DURATION_MINUTES"), "60"));
 
 	/**
 	 * Start the service.
@@ -37,7 +40,7 @@ public class HistoryService {
 				.bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS))
 				.inputTopic(this.config.getString(ConfigurationKeys.KAFKA_INPUT_TOPIC))
 				.outputTopic(this.config.getString(ConfigurationKeys.KAFKA_OUTPUT_TOPIC))
-				.windowDuration(Duration.ofMinutes(this.config.getInt(ConfigurationKeys.KAFKA_WINDOW_DURATION_MINUTES)))
+				.windowDuration(Duration.ofMinutes(this.KAFKA_WINDOW_DURATION_MINUTES))
 				.numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS))
 				.commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS))
 				.cacheMaxBytesBuffering(this.config.getInt(ConfigurationKeys.CACHE_MAX_BYTES_BUFFERING)).build();
diff --git a/uc3-application/src/main/resources/META-INF/application.properties b/uc3-application/src/main/resources/META-INF/application.properties
new file mode 100644
index 000000000..d2002fd1c
--- /dev/null
+++ b/uc3-application/src/main/resources/META-INF/application.properties
@@ -0,0 +1,6 @@
+kafka.bootstrap.servers=localhost:9092
+kafka.input.topic=input
+kafka.output.topic=output
+num.threads=1
+commit.interval.ms=10
+cache.max.bytes.buffering=-1
-- 
GitLab