java – Kafka Connect实现错误

我在这里运行教程： http://kafka.apache.org/documentation.html#introduction

当我进入“步骤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)此问题已得到解决.

（编辑：安卓应用网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!