flume 在配置source 访问avro 的时候,能使用socket 发送数据给avro,可以接受吗
在本地使用socket 编程 去调用远程的flume机器,发现有个 org.apache.avro.AvroRuntimeException: Excessively large list allocation request detected: 16843009 items! Connection closed. 问题 不清楚如何解决
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(2)
您好,我也想问这个问题,请问您知道the answer吗
client Avro格式 是通过RPC方式交互,JAVA有API,而C C++版本 AVRO官网尚无相应的API,所以说,如果是C C++显示SOKET开发是不可行的,即使组对了event消息,发过去,flume那头解析不了。java直接调avro rpc api即可。仅供参考!