diff --git a/src/main/java/com/salesforce/mirus/config/TaskConfig.java b/src/main/java/com/salesforce/mirus/config/TaskConfig.java
index 6f51f04..efc70d9 100644
--- a/src/main/java/com/salesforce/mirus/config/TaskConfig.java
+++ b/src/main/java/com/salesforce/mirus/config/TaskConfig.java
@@ -75,6 +75,7 @@ public boolean getEnablePartitionMatching() {
   public Converter getKeyConverter() {
     Map<String, Object> conf = simpleConfig.originals();
     conf.put(StringConverterConfig.TYPE_CONFIG, ConverterType.KEY.getName());
+    conf.putAll(simpleConfig.originalsWithPrefix(SourceConfigDefinition.SOURCE_KEY_CONVERTER.key + "."));
 
     SimpleConfig config = new SimpleConfig(TaskConfigDefinition.configDef(), conf);
 
@@ -85,6 +86,7 @@ public Converter getKeyConverter() {
   public Converter getValueConverter() {
     Map<String, Object> conf = simpleConfig.originals();
     conf.put(StringConverterConfig.TYPE_CONFIG, ConverterType.VALUE.getName());
+    conf.putAll(simpleConfig.originalsWithPrefix(SourceConfigDefinition.SOURCE_VALUE_CONVERTER.key + "."));
 
     SimpleConfig config = new SimpleConfig(TaskConfigDefinition.configDef(), conf);
 
@@ -95,6 +97,7 @@ public Converter getValueConverter() {
   public HeaderConverter getHeaderConverter() {
     Map<String, Object> conf = simpleConfig.originals();
     conf.put(StringConverterConfig.TYPE_CONFIG, ConverterType.HEADER.getName());
+    conf.putAll(simpleConfig.originalsWithPrefix(SourceConfigDefinition.SOURCE_HEADER_CONVERTER.key + "."));
 
     SimpleConfig config = new SimpleConfig(TaskConfigDefinition.configDef(), conf);