当我进入“步骤7：使用Kafka Connect导入/导出数据”并尝试启动两个连接器时,我收到以下错误：
ERROR Failed to flush WorkerSourceTask{id=local-file-source-0},timed out while waiting for producer to flush outstanding messages,1 left
ERROR Failed to commit offsets for WorkerSourceTask
这是教程的一部分：
Next,we’ll start two connectors running in standalone mode,which means they run in a single,local,dedicated process. We provide three configuration files as parameters. The first is always the configuration for the Kafka Connect process,containing common configuration such as the Kafka brokers to connect to and the serialization format for data. The remaining configuration files each specify a connector to create. These files include a unique connector name,the connector class to instantiate,and any other configuration required by the connector.
bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties
我花了一些时间寻找解决方案,但无法找到任何有用的东西.任何帮助表示赞赏.
谢谢！
解决方法
一旦我使用服务器属性启动kafka服务器(config / server.properties)此问题已得到解决.