kafka-connect-spooldir
kafka-connect-spooldir copied to clipboard
SpoolDirLineDelimitedSourceConnector cleanup policy
when the connector move file to the finished.path, he add subfolder with the name of the file and add the file to it.
config: "input.file.pattern": "^.+\.txt$", "input.path": "/app/vol/testconnect/source", "error.path": "/app/vol/testconnect/error", "finished.path": "/app/vol/testconnect/move",
this is the log that we can see:
INFO [spooldir_test_connect_standalone|task-0] Closing /app/vol/testconnect/source/test_1.txt (com.github.jcustenborder.kafka.connect.spooldir.InputFile:192)
INFO [spooldir_test_connect_standalone|task-0] Moving /app/vol/testconnect/source/test_1.txt to /app/vol/testconnect/move/test_1.txt/test_1.txt
it worked fine with jcustenborder-kafka-connect-spooldir-2.0.62 but now with jcustenborder-kafka-connect-spooldir-2.0.65