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 这是教程的一部分:
我花了一些时间寻找解决方案,但无法找到任何有用的东西.任何帮助表示赞赏. 谢谢! 解决方法
我收到此错误的原因是因为我使用config / server.properties创建的第一台服务器未运行.我假设因为它是主题的主角,消息无法刷新,并且无法提交偏移.
一旦我使用服务器属性启动kafka服务器(config / server.properties)此问题已得到解决. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
- 不活动后调用java.beans.Introspector.getBeanIn
- Java常见问题之javac Hello.java找不到文件的解决
- java – 如何将两个字节附加到int
- resume|issue|transmit|sake|obliged|beyond her
- “java”插件与Android插件不兼容
- java swing标准对话框具体实现
- 单元测试 – 单元测试Vertx – java.util.concur
- Java单例模式下的MongoDB数据库操作工具类
- 我应该将什么字符串传递给java.lang.Long.parseL
- 关于Object数组强转成Integer数组的问题:Ljava.