flume 在配置source 访问avro 的时候,能使用socket 发送数据给avro,可以接受吗

发布于 2021-11-27 18:22:42 字数 187 浏览 888 评论 2

在本地使用socket 编程 去调用远程的flume机器,发现有个 org.apache.avro.AvroRuntimeException: Excessively large list allocation request detected: 16843009 items! Connection closed.  问题 不清楚如何解决 

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(2

秋意浓 2021-11-30 09:21:16

您好,我也想问这个问题,请问您知道the answer吗

奢望 2021-11-29 19:29:29

client Avro格式 是通过RPC方式交互,JAVA有API,而C C++版本 AVRO官网尚无相应的API,所以说,如果是C C++显示SOKET开发是不可行的,即使组对了event消息,发过去,flume那头解析不了。java直接调avro rpc api即可。仅供参考!

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文