Flume - 当 MemoryChannel 无法处理事件时会发生什么?

问题描述

考虑带有 EmbeddedAgentMemoryChannel(在 Java 应用程序中运行)和一些连接到远程服务器的接收器的用例。

我在 Flume 文档中阅读了内存通道的配置设置:

  • capacity:频道中的最大事件数
  • byteCapacity:通道中数据的最大总大小(以标头为模数)

我的问题是:如果接收器由于某种原因无法跟上速度并且达到了 capacitybyteCapacity 两个限制中的任何一个,会发生什么情况?

事件是否刚刚被丢弃并且进程继续正常运行(除了一些事件丢失)?

我在文档中找不到对此的明确解释,感谢您帮助理解这一点。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)