Skip to content
Snippets Groups Projects
Commit 1cf7ad63 authored by Björn Vonheiden's avatar Björn Vonheiden
Browse files

Add missing schema registry configuration in code

parent b9aeab84
No related branches found
No related tags found
No related merge requests found
...@@ -44,6 +44,7 @@ public class HistoryService { ...@@ -44,6 +44,7 @@ public class HistoryService {
// Configuration of the stream application // Configuration of the stream application
final KafkaStreams kafkaStreams = uc3KafkaStreamsBuilder final KafkaStreams kafkaStreams = uc3KafkaStreamsBuilder
.bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS)) .bootstrapServers(this.config.getString(ConfigurationKeys.KAFKA_BOOTSTRAP_SERVERS))
.schemaRegistry(this.config.getString(ConfigurationKeys.SCHEMA_REGISTRY_URL))
.numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS)) .numThreads(this.config.getInt(ConfigurationKeys.NUM_THREADS))
.commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS)) .commitIntervalMs(this.config.getInt(ConfigurationKeys.COMMIT_INTERVAL_MS))
.cacheMaxBytesBuffering(this.config.getInt(ConfigurationKeys.CACHE_MAX_BYTES_BUFFERING)) .cacheMaxBytesBuffering(this.config.getInt(ConfigurationKeys.CACHE_MAX_BYTES_BUFFERING))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment