Skip to content
Snippets Groups Projects

fix not setting application name in the use case applications

Merged Björn Vonheiden requested to merge stu202077/theodolite:fix/applicationNameCrash into master
9 files
+ 35
9
Compare changes
  • Side-by-side
  • Inline
Files
9
@@ -46,6 +46,8 @@ public class AggregationService {
// Configuration of the stream application
final KafkaStreams kafkaStreams = uc2KafkaStreamsBuilder
.applicationName(this.config.getString(ConfigurationKeys.APPLICATION_NAME))
.applicationVersion(this.config.getString(ConfigurationKeys.APPLICATION_VERSION))
.bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS))
.numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS))
.commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS))
Loading