flume代码编写Flume采集需求:服务器的某特定文件中,会不断产生新的数据信息,每当该文件有新内容更新时,就需要把文件中新的数据采集到 logger日志中去。(1)数据采集源:即 source -- 监控文件: exec,其中监控的文件的路径为/flume/data/test.txt (2)数据最终的存储目标:即 sink --logger日志文件 :logger sink(3)source 和 sink 之间的传递通道: 即channel ,用 内存 memory channel 。请完整的写出一份flume的配置文件。1.#定义三个组件source、sink、channel并分别设置属性和名字, 其中要求Agent的名字为a01,三个组件的名字可以自拟。 2.#关于souces的配置项目 3.#关于sinks的配置项目 4.#关于channel的配置项目 5.#让souces和sink与channel进行关联
发布时间:2024-05-21 10:25:00