看的官方手册使用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
试过重启服务,不行