返回到文章

采纳

编辑于

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

kafka

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

试过重启服务,不行