diff --git a/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java b/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java index d1705888430c92ee0cec50ea06871746bbe06cb5..c71c472e262a6efe22bcdbb88127710ade572724 100644 --- a/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java +++ b/theodolite-benchmarks/hazelcastjet-commons/src/main/java/rocks/theodolite/benchmarks/commons/hazelcastjet/ConfigurationKeys.java @@ -5,15 +5,17 @@ package rocks.theodolite.benchmarks.commons.hazelcastjet; */ public class ConfigurationKeys { + public static final String APPLICATION_NAME = "application.name"; + // Common Keys public static final String BOOTSTRAP_SERVER = "BOOTSTRAP_SERVER"; public static final String KUBERNETES_DNS_NAME = "KUBERNETES_DNS_NAME"; public static final String PORT = "PORT"; public static final String PORT_AUTO_INCREMENT = "PORT_AUTO_INCREMENT"; public static final String CLUSTER_NAME_PREFIX = "CLUSTER_NAME_PREFIX"; - 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"; + 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"; // Additional topics public static final String KAFKA_OUTPUT_TOPIC = "KAFKA_OUTPUT_TOPIC";