Flume框架关于 Channel 遇到峰值的处理方式是怎样的?
问题描述:
我的理解是 Source 是一个单独的线程,不断的往 Channel 中丢 Event,
Sink 也是一个单独的线程,不断的从 Channel 中拿出 Event,
Channel 作为 Agent 的缓冲区是有一定的容量的,
假如 Sink 端遇到特殊情况阻塞了,这个时候如果 Source 一直丢 Event 过来,那 Channel 中已经满了,这种情况下 Source 会怎么处理?或者说 Agent 会怎么处理?
麻烦老师解答 ~
4
收起
正在回答 回答被采纳积分+1
1回答
相似问题
登录后可查看更多问答,登录/注册
恭喜解决一个难题,获得1积分~
来为老师/同学的回答评分吧
0 星