看的官方手册使用connect来导入数据,命令输入后总显示错误网上也找不到相关信息
bin\windows\connect-standalone.bat config\connect-standalone.properties config\connect-file-source.properties config\connect-file-sink.properties
[2020-01-09 17:09:47,883] WARN The configuration 'offset.flush.interval.ms' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:47,883] WARN The configuration 'key.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:47,884] WARN The configuration 'offset.storage.file.filename' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:47,884] WARN The configuration 'value.converter.schemas.enable' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:47,885] WARN The configuration 'value.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:47,885] WARN The configuration 'key.converter' was supplied but isn't a known config. (org.apache.kafka.clients.admin.AdminClientConfig)
[2020-01-09 17:09:49,471] ERROR Plugin class loader for connector: 'FileStreamSink' was not found. Returning: org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@5f9678e1 (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader)
[2020-01-09 17:16:44,044] ERROR Error while trying to seek to previous offset in file test.txt: (org.apache.kafka.connect.file.FileStreamSourceTask)
java.nio.channels.AsynchronousCloseException
试过重启服务,不行
windowns的没试过,都是在linux上操作的,不过看
ERROR Plugin class loader for connector: 'FileStreamSink' was not found.`
是缺类,打包像是漏了,或者是环境没引入。
config\connect-standalone.properties
这个文件里的问题你的答案