Flume架构：事件向Channel传递及SpoolDir源拦截器处理逻辑问询

Great question! Let me break this down clearly for you:

• 核心逻辑：逐个拦截事件，再发送至Channel
  SpoolDirSource的工作机制是逐行读取监控目录下的目标文件，每一行内容会被封装成一个独立的Flume Event。拦截器的触发时机是每个Event创建完成后、即将发送到Channel之前——也就是说，每生成一个Event，就会立刻进入拦截器处理流程（如果配置了多个拦截器，会按配置顺序依次执行），处理完毕的Event才会被加入Channel的事务队列，最终提交到Channel中。

• 为什么不是批量拦截后再发送？
  SpoolDirSource本身被设计为流式逐行处理模式，不会先把整个文件的内容全部转换成Event再统一处理。这种逐个处理的逻辑既符合Flume的事件驱动模型，保证了数据的实时性，也能避免大文件一次性加载带来的内存压力。

  补充说明：即使你配置了Channel的批量提交参数（比如transactionCapacity），这也只是Channel层面的提交优化，拦截器依然会对每个单独的Event做处理，而非批量处理所有Event后再统一提交。

内容的提问来源于stack exchange，提问作者Ana Caroline Sanchez Silva