知道Flume的Channel是什么吗?
发布时间:2022-09-01 15:59:56
发布人:wjy
Channel 被设计为 Event 中转临时缓冲区,存储 Source 收集并且没有被 Sink 读取的 Event,为平衡 Source 收集和 Sink 读取的速度,可视为 Flume 内部的消息队列。
Channel 线程安全并且具有事务性,支持 Source 写失败写,和 Sink 读失败重复读的操作。
常见的类型包括 Memory Channel,File Channel,Kafka Channel。