- Fixing override of main config ✨

fairyhunter13 · Jun 22, 2020 · 601b3c1 · 601b3c1
1 parent f7b909c
commit 601b3c1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/container_config.go b/container_config.go
@@ -4,8 +4,8 @@ import "github.com/confluentinc/confluent-kafka-go/kafka"
 
 func (c *Container) initConfig(config kafka.ConfigMap) (newConfig kafka.ConfigMap) {
 	if config != nil {
-		newConfig = c.cloneConfig(config)
-		c.appendConfigMap(c.configMap, newConfig)
+		newConfig = c.cloneConfig(c.configMap)
+		c.appendConfigMap(config, newConfig)
 	} else {
 		newConfig = c.cloneConfig(c.configMap)
 	}