diff --git a/config/config.go b/config/config.go
index 0f54232..be36886 100644
--- a/config/config.go
+++ b/config/config.go
@@ -40,8 +40,8 @@ func (k *Kafka) GetCompression() int8 {
 }
 
 type Connector struct {
-	Kafka Kafka      `yaml:"kafka"`
-	Dcp   config.Dcp `yaml:",inline"`
+	Kafka Kafka      `yaml:"kafka" mapstructure:"kafka"`
+	Dcp   config.Dcp `yaml:",inline" mapstructure:",squash"`
 }
 
 func (c *Connector) ApplyDefaults() {