因此,在flume架构中,我们将数据发送到源,源写入通道,通道将事件发送到接收器,接收器执行它需要执行的操作。
我目前有一个flume代理,使用内存通道、avrosource和hdfssink。
为了将数据发送到avrosource,我使用了flume ng sdk,它向我推荐appendbatch方法。
如果事件没有像文档中所说的那样传递到“至少他的下一个跃点”,这个appendbatch方法就会抛出一个异常。
每当事件未能到达至少一个预期(下一跃点)目的地时,就会引发事件传递异常。
但我的问题是,这里的“下一跳目的地”是什么?是频道吗?还是源头?
我认为这很重要,我很难理解它。
一些用例需要确保在通道上接收到事件,因为在通道上我们有一些持久性特性。
暂无答案!
目前还没有任何答案,快来回答吧!