Kafka的SpoolDirCsvSourceConnector返回错误“必须是目录”

pcrecxhr  于 2023-01-04  发布在  Apache
关注(0)|答案(1)|浏览(110)

我正在按照https://rmoff.net/2020/06/17/loading-csv-data-into-kafka/中提供的教程将数据从csv移动到Kafka。我的文件夹结构类似于https://github.com/confluentinc/demo-scene/tree/master/csv-to-kafka中的文件夹结构。

但是,每当我尝试执行连接器时

curl -i -X PUT -H "Accept:application/json" \
        -H  "Content-Type:application/json" http://localhost:8083/connectors/source-csv-spooldir-00/config \
        -d '{
            "connector.class": "com.github.jcustenborder.kafka.connect.spooldir.SpoolDirCsvSourceConnector",
            "topic": "orders_spooldir_00",
            "input.path": "/data/unprocessed",
            "finished.path": "/data/processed",
            "error.path": "/data/error",
            "input.file.pattern": ".*\\.csv",
            "schema.generation.enabled":"true",
            "csv.first.row.as.header":"true"
}'

我收到错误消息

有人能告诉我发生了什么事吗?我已经花了几个小时在这上面了

6uxekuva

6uxekuva1#

我也面临着同样的问题,然后我意识到目录必须是由运行Kafka连接的同一个用户可写的。
如果没有,您将总是得到上述错误。

检查official doc

相关问题