开发者社区> 问答> 正文

flume 在配置source 访问avro 的时候,能使用socket 发送数据?- 服务报错

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

展开
收起
montos 2020-05-31 19:02:02 689 0
1 条回答
写回答
取消 提交回答
  • client Avro格式 是通过RPC方式交互,JAVA有API,而C C++版本 AVRO官网尚无相应的API,所以说,如果是C C++显示SOKET开发是不可行的,即使组对了event消息,发过去,flume那头解析不了。java直接调avro rpc api即可。仅供参考!######

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

    2020-05-31 19:02:10
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Kafka and the Rise of Stream Processing 立即下载
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载
gohbase :HBase go客户端 立即下载