CsvSpoolDir error out

[edgrt]

Hi,

I am new to confluent/kafka. I was following this tutorial.
https://docs.confluent.io/kafka-connect-spooldir/current/overview.html.

when I checked the connector status I get the below message.

confluent local services connect connector status CsvSpoolDir

The local commands are intended for a single-node development environment only,
NOT for production usage. https://docs.confluent.io/current/cli/index.html

{
"name": "CsvSpoolDir",
"connector": {
"state": "FAILED",
"worker_id": "12.3.321.192:8083",
"trace": "java.lang.IllegalStateException: Could not find any input file(s) to infer schema from.\n\tat shaded.com.google.common.base.Preconditions.checkState(Preconditions.java:508)\n\tat com.github.jcustenborder.kafka.connect.spooldir.AbstractSpoolDirSourceConnector.start(AbstractSpoolDirSourceConnector.java:63)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doStart(WorkerConnector.java:185)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.start(WorkerConnector.java:210)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:349)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doTransitionTo(WorkerConnector.java:332)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.doRun(WorkerConnector.java:141)\n\tat org.apache.kafka.connect.runtime.WorkerConnector.run(WorkerConnector.java:118)\n\tat java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)\n\tat java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)\n\tat java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)\n\tat java.base/java.lang.Thread.run(Thread.java:829)\n"

[cande1gut]

@edgrt You need a CSV file already in the input folder before starting the connector, so the schema is read and sent through the topic