开发者社区> 问答> 正文

flume 在配置source 访问avro 的时候,能使用socket 发送数据给avro。:报错

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

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

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

    2020-06-07 10:18:24
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Kafka and the Rise of Stream Processing 立即下载
BUILDING REALTIME DATA PIPELINES WITH KAFKA CONNECT AND SPARK STREAMING 立即下载
Stream Processing with Apache RocketMQ 立即下载