diff --git a/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceConnectorConfig.java b/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceConnectorConfig.java
index 3b1c6a5..3c5787f 100644
--- a/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceConnectorConfig.java
+++ b/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceConnectorConfig.java
@@ -62,10 +62,10 @@ public class DynamoDBSourceConnectorConfig extends AbstractConfig {
 	public static final String DST_TOPIC_PREFIX_DISPLAY = "Topic prefix";
 	public static final String DST_TOPIC_PREFIX_DEFAULT = "dynamodb-";
 
-	public static final String DST_TOPIC_NAMESPACE_MAP_CONFIG = "kafka.topic.namespace.map";
-	public static final String DST_TOPIC_NAMESPACE_MAP_DOC = "Define Kafka topic namespace map.";
-	public static final String DST_TOPIC_NAMESPACE_MAP_DISPLAY = "Topic namespace map";
-	public static final String DST_TOPIC_NAMESPACE_MAP_DEFAULT = null;
+	public static final String DST_TOPIC_MAP_CONFIG = "kafka.topic.map";
+	public static final String DST_TOPIC_MAP_DOC = "Define Kafka topic namespace map.";
+	public static final String DST_TOPIC_MAP_DISPLAY = "Topic namespace map";
+	public static final String DST_TOPIC_MAP_DEFAULT = null;
 
 	public static final String REDISCOVERY_PERIOD_CONFIG = "connect.dynamodb.rediscovery.period";
 	public static final String REDISCOVERY_PERIOD_DOC = "Time period in milliseconds to rediscover stream enabled DynamoDB tables";
@@ -194,14 +194,14 @@ public static ConfigDef baseConfigDef() {
 						ConfigDef.Width.MEDIUM,
 						DST_TOPIC_PREFIX_DISPLAY)
 				
-				.define(DST_TOPIC_NAMESPACE_MAP_CONFIG,
+				.define(DST_TOPIC_MAP_CONFIG,
 						ConfigDef.Type.STRING,
-						DST_TOPIC_NAMESPACE_MAP_DEFAULT,
+						DST_TOPIC_MAP_DEFAULT,
 						ConfigDef.Importance.HIGH,
-						DST_TOPIC_NAMESPACE_MAP_DOC,
+						DST_TOPIC_MAP_DOC,
 						CONNECTOR_GROUP, 2,
 						ConfigDef.Width.LONG,
-						DST_TOPIC_NAMESPACE_MAP_DISPLAY)
+						DST_TOPIC_MAP_DISPLAY)
 
 				.define(SRC_INIT_SYNC_DELAY_CONFIG,
 						ConfigDef.Type.INT,
@@ -262,8 +262,8 @@ public String getDestinationTopicPrefix() {
 		return getString(DST_TOPIC_PREFIX_CONFIG);
 	}
 
-	public String getDestinationTopicNamespaceMap() {
-		return getString(DST_TOPIC_NAMESPACE_MAP_CONFIG);
+	public String getDestinationTopicMap() {
+		return getString(DST_TOPIC_MAP_CONFIG);
 	}
 
 	public long getRediscoveryPeriod() {
diff --git a/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceTask.java b/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceTask.java
index dc39d01..63ab6c3 100644
--- a/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceTask.java
+++ b/source/src/main/java/com/trustpilot/connector/dynamodb/DynamoDBSourceTask.java
@@ -134,7 +134,7 @@ public void start(Map<String, String> configProperties) {
                     tableDesc.getTableName(),
                     tableDesc.getProvisionedThroughput().getReadCapacityUnits());
         }
-        converter = new RecordConverter(tableDesc, config.getDestinationTopicPrefix(), config.getDestinationTopicNamespaceMap());
+        converter = new RecordConverter(tableDesc, config.getDestinationTopicPrefix(), config.getDestinationTopicMap());
 
         LOGGER.info("Starting background KCL worker thread for table: {}", tableDesc.getTableName());