You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
@@ -30,6 +30,7 @@ These configurations are described in detail in subsequent chapters.
30
30
|`fs.cleanup.policy.class`| The fully qualified name of the class which is used to cleanup files | class |*-*| HIGH |
31
31
|`fs.cleanup.policy.triggered.on`| Specify the status when a file get cleanup. Valid values are: `COMPLETED`, `COMMITTED`| string |*COMPLETED*| MEDIUM |
32
32
|`max.scheduled.files`| Maximum number of files that can be schedules to tasks. | long |*1000*| HIGH |
33
+
|`allow.tasks.reconfiguration.after.timeout.ms`| Specify the timeout (in milliseconds) for the connector to allow tasks to be reconfigured when new files are detected, even if some tasks are still being processed. | long |*-*| LOW |
33
34
|`task.partitioner.class`| The TaskPartitioner to be used for partitioning files to tasks. | class |`io.streamthoughts.kafka.connect.filepulse.source.DefaultTaskPartitioner`| HIGH |
34
35
|`tasks.halt.on.error`| Should a task halt when it encounters an error or continue to the next file. | boolean |*false*| HIGH |
35
36
|`tasks.empty.poll.wait.ms`| The amount of time in millisecond a tasks should wait if a poll returns an empty list of records. | long |*500*| HIGH |
0 commit comments