diff --git a/uc2-application/src/main/java/theodolite/uc2/application/ConfigurationKeys.java b/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java similarity index 67% rename from uc2-application/src/main/java/theodolite/uc2/application/ConfigurationKeys.java rename to application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java index 5bfb3dc7c71651322dbd32d410e4d204163f8582..af05c51bd6ad79a38dfef0dd9961b881d3c32006 100644 --- a/uc2-application/src/main/java/theodolite/uc2/application/ConfigurationKeys.java +++ b/application-kafkastreams-commons/src/main/java/theodolite/commons/kafkastreams/ConfigurationKeys.java @@ -1,29 +1,41 @@ -package theodolite.uc2.application; +package theodolite.commons.kafkastreams; /** * Keys to access configuration parameters. */ public final class ConfigurationKeys { + // Common keys + public static final String APPLICATION_NAME = "application.name"; - public static final String CONFIGURATION_KAFKA_TOPIC = "configuration.kafka.topic"; + public static final String APPLICATION_VERSION = "application.version"; + + public static final String NUM_THREADS = "num.threads"; + + public static final String COMMIT_INTERVAL_MS = "commit.interval.ms"; + + public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers"; - public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic"; + public static final String SCHEMA_REGISTRY_URL = "schema.registry.url"; public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic"; + // Additional topics + public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic"; + + public static final String CONFIGURATION_KAFKA_TOPIC = "configuration.kafka.topic"; + + // UC2 public static final String WINDOW_SIZE_MS = "window.size.ms"; public static final String WINDOW_GRACE_MS = "window.grace.ms"; - public static final String NUM_THREADS = "num.threads"; + // UC4 + public static final String AGGREGATION_DURATION_DAYS = "aggregation.duration.days"; - public static final String COMMIT_INTERVAL_MS = "commit.interval.ms"; - - public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; + public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days"; - public static final String SCHEMA_REGISTRY_URL = "schema.registry.url"; private ConfigurationKeys() {} diff --git a/uc1-application/src/main/java/theodolite/uc1/application/ConfigurationKeys.java b/uc1-application/src/main/java/theodolite/uc1/application/ConfigurationKeys.java deleted file mode 100644 index ec2e023e1af8641daed738d371b4497ccabbfb84..0000000000000000000000000000000000000000 --- a/uc1-application/src/main/java/theodolite/uc1/application/ConfigurationKeys.java +++ /dev/null @@ -1,27 +0,0 @@ -package theodolite.uc1.application; - -/** - * Keys to access configuration parameters. - */ -public final class ConfigurationKeys { - - public static final String APPLICATION_NAME = "application.name"; - - public static final String APPLICATION_VERSION = "application.version"; - - public static final String NUM_THREADS = "num.threads"; - - public static final String COMMIT_INTERVAL_MS = "commit.interval.ms"; - - public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; - - public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers"; - - public static final String SCHEMA_REGISTRY_URL = "schema.registry.url"; - - public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic"; - - - private ConfigurationKeys() {} - -} diff --git a/uc1-application/src/main/java/theodolite/uc1/application/HistoryService.java b/uc1-application/src/main/java/theodolite/uc1/application/HistoryService.java index 8f54267e8e726e9717479e2e415e69051089901e..a35cc37b36fb906e5c5495006126374d4de4656c 100644 --- a/uc1-application/src/main/java/theodolite/uc1/application/HistoryService.java +++ b/uc1-application/src/main/java/theodolite/uc1/application/HistoryService.java @@ -3,6 +3,7 @@ package theodolite.uc1.application; import java.util.concurrent.CompletableFuture; import org.apache.commons.configuration2.Configuration; import org.apache.kafka.streams.KafkaStreams; +import theodolite.commons.kafkastreams.ConfigurationKeys; import theodolite.uc1.streamprocessing.Uc1KafkaStreamsBuilder; import titan.ccp.common.configuration.ServiceConfigurations; diff --git a/uc2-application/src/main/java/theodolite/uc2/application/AggregationService.java b/uc2-application/src/main/java/theodolite/uc2/application/AggregationService.java index 74ab2c21779ce6eb742a2ffb9a82157979ed5acc..1be3fb8da2e00c90c242649536ba980e3a0a1443 100644 --- a/uc2-application/src/main/java/theodolite/uc2/application/AggregationService.java +++ b/uc2-application/src/main/java/theodolite/uc2/application/AggregationService.java @@ -4,6 +4,7 @@ import java.time.Duration; import java.util.concurrent.CompletableFuture; import org.apache.commons.configuration2.Configuration; import org.apache.kafka.streams.KafkaStreams; +import theodolite.commons.kafkastreams.ConfigurationKeys; import theodolite.uc2.streamprocessing.Uc2KafkaStreamsBuilder; import titan.ccp.common.configuration.ServiceConfigurations; diff --git a/uc3-application/src/main/java/theodolite/uc3/application/ConfigurationKeys.java b/uc3-application/src/main/java/theodolite/uc3/application/ConfigurationKeys.java deleted file mode 100644 index d95d245e0b354f11abfc40277e088f1a3f205c95..0000000000000000000000000000000000000000 --- a/uc3-application/src/main/java/theodolite/uc3/application/ConfigurationKeys.java +++ /dev/null @@ -1,25 +0,0 @@ -package theodolite.uc3.application; - -/** - * Keys to access configuration parameters. - */ -public final class ConfigurationKeys { - - public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers"; - - public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic"; - - public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic"; - - public static final String NUM_THREADS = "num.threads"; - - public static final String COMMIT_INTERVAL_MS = "commit.interval.ms"; - - public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; - - public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes"; - - private ConfigurationKeys() { - } - -} diff --git a/uc3-application/src/main/java/theodolite/uc3/application/HistoryService.java b/uc3-application/src/main/java/theodolite/uc3/application/HistoryService.java index 916d64f011a742d497a3512dd09da9db080576e5..db7ec3ba6ed3c541a242f32c67306f1ec8e6e85e 100644 --- a/uc3-application/src/main/java/theodolite/uc3/application/HistoryService.java +++ b/uc3-application/src/main/java/theodolite/uc3/application/HistoryService.java @@ -5,6 +5,7 @@ import java.util.Objects; import java.util.concurrent.CompletableFuture; import org.apache.commons.configuration2.Configuration; import org.apache.kafka.streams.KafkaStreams; +import theodolite.commons.kafkastreams.ConfigurationKeys; import theodolite.uc3.streamprocessing.Uc3KafkaStreamsBuilder; import titan.ccp.common.configuration.Configurations; diff --git a/uc4-application/src/main/java/theodolite/uc4/application/ConfigurationKeys.java b/uc4-application/src/main/java/theodolite/uc4/application/ConfigurationKeys.java deleted file mode 100644 index aa74e1552cb4c3c020f511dfb6b53a3f1fd886d7..0000000000000000000000000000000000000000 --- a/uc4-application/src/main/java/theodolite/uc4/application/ConfigurationKeys.java +++ /dev/null @@ -1,28 +0,0 @@ -package theodolite.uc4.application; - -/** - * Keys to access configuration parameters. - */ -public final class ConfigurationKeys { - - public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers"; - - public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic"; - - public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic"; - - public static final String AGGREGATION_DURATION_DAYS = "aggregation.duration.days"; - - public static final String AGGREGATION_ADVANCE_DAYS = "aggregation.advance.days"; - - public static final String NUM_THREADS = "num.threads"; - - public static final String COMMIT_INTERVAL_MS = "commit.interval.ms"; - - public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering"; - - public static final String KAFKA_WINDOW_DURATION_MINUTES = "kafka.window.duration.minutes"; - - private ConfigurationKeys() {} - -} diff --git a/uc4-application/src/main/java/theodolite/uc4/application/HistoryService.java b/uc4-application/src/main/java/theodolite/uc4/application/HistoryService.java index 4d686d8f7f244b9e6dd28b4c39abcb83d9a108b8..a27ea6711a5ee734d4b925bde49cbba8837137f2 100644 --- a/uc4-application/src/main/java/theodolite/uc4/application/HistoryService.java +++ b/uc4-application/src/main/java/theodolite/uc4/application/HistoryService.java @@ -4,6 +4,7 @@ import java.time.Duration; import java.util.concurrent.CompletableFuture; import org.apache.commons.configuration2.Configuration; import org.apache.kafka.streams.KafkaStreams; +import theodolite.commons.kafkastreams.ConfigurationKeys; import theodolite.uc4.streamprocessing.Uc4KafkaStreamsBuilder; import titan.ccp.common.configuration.Configurations;