我正在按照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"
}'
我收到错误消息
有人能告诉我发生了什么事吗?我已经花了几个小时在这上面了
1条答案
按热度按时间6uxekuva1#
我也面临着同样的问题,然后我意识到目录必须是由运行Kafka连接的同一个用户可写的。
如果没有,您将总是得到上述错误。
检查official doc