【Flume中间件】(14)自定义Sink

自定义Sink自定义Sink的流程就是:首先需要或取sink对应的channel,然后从指定的channel中获取事务,然后再从channel中拉取事件,将事件进行处理,根据业务逻辑将数据写出,然后提交事务,如果成功,channel将该事件清除,否则进行回滚。a1.sou...

【Flume中间件】(10)sink组负载均衡

sink组负载均衡负载均衡的目的就是为了防止单个服务器的压力较大,所以采用两个sink进行负载,channel会随机的从sink组中挑选一个sink进行传输。这里有一个问题,我设置了负载均衡,然后配置的是round_robin,采用轮询方式,如果我数据一条一条的发送,最终是进行轮询,将...

【Flume中间件】(9)sink组故障转移

sink组故障转移有的时候需要设置故障转移,就是比如说现在有一个channel,如果只设置一个的话,一旦该sink端崩掉的话就会造成输出数据中断,所以需要就是配置两个sink,并且设置优先级,优先发送哪个,如果优先级高的sink没有问题的话,channel的数据就会一直发送到它...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

社区圈子

阿里中间件
阿里中间件
为企业提供高效、稳定、易扩展的中间件产品
164949+人已加入
加入
相关电子书
更多
云原生中间件重磅发布—全面迎接 Serverless 时代
阿里云中间件开发者大会|分布式应用治理专场演讲合集
阿里云中间件开发者大会|分布式应用架构专场演讲合集
立即下载 立即下载 立即下载