kafka connect来导入数据命令出错。

H₂O₂ 发表于: 2020-01-09   最后更新时间: 2022-07-18 10:21:30   3,328 游览

看的官方手册使用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

试过重启服务,不行

发表于 2020-01-09
添加评论

windowns的没试过,都是在linux上操作的,不过看

ERROR Plugin class loader for connector: 'FileStreamSink' was not found.`

是缺类,打包像是漏了,或者是环境没引入。

config\connect-standalone.properties这个文件里的问题

你的答案

查看kafka相关的其他问题或提一个您自己的问题