Skip to content
Snippets Groups Projects
Commit 59e5f1e6 authored by Benedikt Wetzel's avatar Benedikt Wetzel
Browse files

clean up

parent b531fed4
No related branches found
No related tags found
1 merge request!1Add Implementations of Use Cases
cassandra.host=localhost
cassandra.port=9042
cassandra.keyspace=titanccp
cassandra.init.timeout.ms=30000
webserver.enable=true
webserver.port=8081
webserver.cors=true
webserver.gzip=false
kafka.bootstrap.servers=localhost:9092 kafka.bootstrap.servers=localhost:9092
kafka.input.topic=input kafka.input.topic=input
kafka.output.topic=output kafka.output.topic=output
......
...@@ -5,34 +5,19 @@ package uc1.application; ...@@ -5,34 +5,19 @@ package uc1.application;
*/ */
public final class ConfigurationKeys { public final class ConfigurationKeys {
public static final String CASSANDRA_HOST = "cassandra.host"; public static final String KAFKA_BOOTSTRAP_SERVERS = "kafka.bootstrap.servers";
public static final String CASSANDRA_PORT = "cassandra.port"; public static final String KAFKA_OUTPUT_TOPIC = "kafka.output.topic";
public static final String CASSANDRA_KEYSPACE = "cassandra.keyspace"; public static final String KAFKA_INPUT_TOPIC = "kafka.input.topic";
public static final String CASSANDRA_INIT_TIMEOUT_MS = "cassandra.init.timeout.ms"; public static final String NUM_THREADS = "num.threads";
public static final String WEBSERVER_ENABLE = "webserver.enable"; public static final String COMMIT_INTERVAL_MS = "commit.interval.ms";
public static final String WEBSERVER_PORT = "webserver.port"; public static final String CACHE_MAX_BYTES_BUFFERING = "cache.max.bytes.buffering";
public static final String WEBSERVER_CORS = "webserver.cors"; private ConfigurationKeys() {
}
public static final String WEBSERVER_GZIP = "webserver.gzip";
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";
private ConfigurationKeys() {}
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment