Integrate object dist strategies

Aiven-Open · Jan 9, 2025 · a7d4e9b · a7d4e9b
1 parent 9800843
commit a7d4e9b
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/commons/src/main/java/io/aiven/kafka/connect/common/config/FileNameFragment.java b/commons/src/main/java/io/aiven/kafka/connect/common/config/FileNameFragment.java
@@ -46,8 +46,8 @@ public final class FileNameFragment extends ConfigFragment {
     public static final String FILE_NAME_TEMPLATE_CONFIG = "file.name.template";
     static final String DEFAULT_FILENAME_TEMPLATE = "{{topic}}-{{partition}}-{{start_offset}}";
 
-    public static final String FILE_PREFIX_TEMPLATE_CONFIG = "file.prefix.template";
-    static final String DEFAULT_FILE_PREFIX_TEMPLATE = "topics/{{topic}}/partition={{partition}}/";
+    public static final String FILE_PATH_PREFIX_TEMPLATE_CONFIG = "file.prefix.template";
+    static final String DEFAULT_FILE_PATH_PREFIX_TEMPLATE = "topics/{{topic}}/partition={{partition}}/";
 
     public FileNameFragment(final AbstractConfig cfg) {
         super(cfg);
@@ -115,15 +115,15 @@ public void ensureValid(final String name, final Object value) {
                 // UnusedAssignment
                 ConfigDef.Width.SHORT, FILE_NAME_TIMESTAMP_SOURCE);
 
-        configDef.define(FILE_PREFIX_TEMPLATE_CONFIG, ConfigDef.Type.STRING, DEFAULT_FILE_PREFIX_TEMPLATE,
+        configDef.define(FILE_PATH_PREFIX_TEMPLATE_CONFIG, ConfigDef.Type.STRING, DEFAULT_FILE_PATH_PREFIX_TEMPLATE,
                 new ConfigDef.NonEmptyString(), ConfigDef.Importance.MEDIUM,
                 "The template for file prefix on S3. "
                         + "Supports `{{ variable }}` placeholders for substituting variables. "
                         + "Currently supported variables are `topic` and `partition` "
                         + "and are mandatory to have these in the directory structure."
                         + "Example prefix : topics/{{topic}}/partition/{{partition}}/",
                 GROUP_FILE, fileGroupCounter++, // NOPMD UnusedAssignment
-                ConfigDef.Width.LONG, FILE_PREFIX_TEMPLATE_CONFIG);
+                ConfigDef.Width.LONG, FILE_PATH_PREFIX_TEMPLATE_CONFIG);
 
         return configDef;
     }
@@ -198,8 +198,8 @@ public int getMaxRecordsPerFile() {
         return cfg.getInt(FILE_MAX_RECORDS);
     }
 
-    public String getFilePrefixTemplateConfig() {
-        return cfg.getString(FILE_PREFIX_TEMPLATE_CONFIG);
+    public String getFilePathPrefixTemplateConfig() {
+        return cfg.getString(FILE_PATH_PREFIX_TEMPLATE_CONFIG);
     }
 
 }