refactor(plugin): change default value of offset.attributes.string to uri (#154)

Resolves: #154

Author: fhussonnois

connect-file-pulse-plugin/src/main/java/io/streamthoughts/kafka/connect/filepulse/offset/DefaultSourceOffsetPolicyConfig.java

@@ -32,7 +32,7 @@ public class DefaultSourceOffsetPolicyConfig extends AbstractConfig {
             "to be used for uniquely identifying an object file; must be one of " +
             "[name, path, lastModified, inode, hash, uri] (e.g: name+hash). Note that order doesn't matter.";
 
-    private static final String OFFSET_ATTRIBUTES_STRING_DEFAULT = "path+name";
+    private static final String OFFSET_ATTRIBUTES_STRING_DEFAULT = "uri";
 
     /**
      * Creates a new {@link ConnectorConfig} instance.

examples/connect-file-pulse-quickstart-avro.json

@@ -6,7 +6,6 @@
   "fs.listing.interval.ms": "10000",
   "internal.kafka.reporter.bootstrap.servers": "broker:29092",
   "internal.kafka.reporter.topic": "connect-file-pulse-status",
-  "offset.attributes.string": "name",
   "read.max.wait.ms": "5000",
   "topic": "connect-file-pulse-quickstart-avro",
   "tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalAvroFileInputReader",

examples/connect-file-pulse-quickstart-log4j.json

@@ -15,7 +15,7 @@
   "fs.listing.filters": "io.streamthoughts.kafka.connect.filepulse.fs.filter.RegexFileListFilter",
   "fs.listing.interval.ms": "10000",
   "file.filter.regex.pattern":".*\\.log$",
-  "offset.attributes.string": "name",
+  "offset.attributes.string": "inode",
   "read.max.wait.ms": "5000",
   "topic": "connect-file-pulse-quickstart-log4j",
   "tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalRowFileInputReader",

examples/connect-file-pulse-quickstart-raw.json

@@ -6,7 +6,6 @@
   "fs.listing.filters":"io.streamthoughts.kafka.connect.filepulse.fs.filter.RegexFileListFilter",
   "fs.listing.interval.ms": "1000",
   "file.filter.regex.pattern":".*\\.csv$",
-  "offset.attributes.string": "name+hash",
   "skip.headers": "1",
   "topic": "connect-file-pulse-quickstart-csv",
   "tasks.reader.class": "io.streamthoughts.kafka.connect.filepulse.fs.reader.LocalBytesArrayInputReader",
@@ -15,5 +14,5 @@
   "tasks.file.status.storage.topic": "connect-file-pulse-status",
   "tasks.file.status.storage.topic.partitions": 10,
   "tasks.file.status.storage.topic.replication.factor": 1,
-  "tasks.max": 2
+  "tasks.max": 4
 }