Merge pull request #48 from aksinghgrd/fix/sqs-source-connector-config

Added configuration for sqs.message.attributes.partition.key
Nordstrom · Mar 6, 2024 · 0f7c4f6 · 0f7c4f6
2 parents f93d9cd + c25c7d8
commit 0f7c4f6
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/nordstrom/kafka/connect/sqs/SqsSinkConnectorConfig.java b/src/main/java/com/nordstrom/kafka/connect/sqs/SqsSinkConnectorConfig.java
@@ -50,7 +50,8 @@ public class SqsSinkConnectorConfig extends SqsConnectorConfig {
       .define(SqsConnectorConfigKeys.SQS_MESSAGE_ATTRIBUTES_INCLUDE_LIST.getValue(), Type.LIST, "", Importance.LOW,
       "The comma separated list of Header names to be included, if empty it includes all the Headers. Default is the empty string.")
       .define(SqsConnectorConfigKeys.CREDENTIALS_PROVIDER_ACCESS_KEY_ID.getValue(), Type.STRING, "", Importance.LOW, "AWS Secret Access Key to be used with Config credentials provider.")
-      .define(SqsConnectorConfigKeys.CREDENTIALS_PROVIDER_SECRET_ACCESS_KEY.getValue(), Type.PASSWORD, "", Importance.LOW, "AWS Secret Access Key to be used with Config credentials provider");
+      .define(SqsConnectorConfigKeys.CREDENTIALS_PROVIDER_SECRET_ACCESS_KEY.getValue(), Type.PASSWORD, "", Importance.LOW, "AWS Secret Access Key to be used with Config credentials provider")
+      .define(SqsConnectorConfigKeys.SQS_MESSAGE_ATTRIBUTE_PARTITION_KEY.getValue(), Type.STRING, "", Importance.LOW, "The name of a single AWS SQS MessageAttribute to use as the partition key");
 
   public static ConfigDef config() {
     return CONFIG_DEF;