Update

bakdata · Jul 23, 2024 · 1798b84 · 1798b84
1 parent 18effda
commit 1798b84
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/KafkaPropertiesFactory.java
@@ -45,6 +45,7 @@ private class Task {
         private final Map<String, Object> kafkaConfig = new HashMap<>();
 
         private Map<String, Object> createKafkaProperties(final Map<String, Object> configOverrides) {
+            this.putAll(KafkaPropertiesFactory.this.baseConfig);
             this.putAll(KafkaPropertiesFactory.this.app.createKafkaProperties());
             final SerializationConfig serializationConfig =
                     KafkaPropertiesFactory.this.app.defaultSerializationConfig();