From 0acf319197703da79587822e773d6cd2cdf11016 Mon Sep 17 00:00:00 2001 From: Nandan H R Date: Wed, 5 Jun 2024 15:53:40 +0530 Subject: [PATCH 1/2] Update topic map config name --- .../DynamoDBSourceConnectorConfig.java | 20 +++++++++---------- .../dynamodb/DynamoDBSourceTask.java | 2 +- 2 files changed, 11 insertions(+), 11 deletions(-) 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..4566a47 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.namespace.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 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()); From da2d87b02c64cc4c40486fcff6c327e4684696ba Mon Sep 17 00:00:00 2001 From: Nandan H R Date: Wed, 5 Jun 2024 15:56:04 +0530 Subject: [PATCH 2/2] Update config value --- .../connector/dynamodb/DynamoDBSourceConnectorConfig.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 4566a47..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,7 +62,7 @@ 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_MAP_CONFIG = "kafka.topic.namespace.map"; + 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;