《Flume日志收集与MapReduce模式》一2.3 从“Hello World”开始
本节书摘来自华章出版社《Flume日志收集与MapReduce模式》一书中的第2章,第2.3节,作者 [美] 史蒂夫·霍夫曼(Steve Hoffman)斯里纳特·佩雷拉(Srinath Perera),更多章节内容可以访问云栖社区“华章计算机”公众号查看
2.3 从“Hello World”开始
每一本技术图书都会有一个“Hello World”示例。下面是我们将会使用的配置文件:
这里定义了一个名为agent的代理,它有一个名为s1的源、一个名为c1的通道,以及一个名为k1的接收器。
源s1的类型为netcat,它只是打开一个Socket监听事件(每个事件一行文本)。它需要两个参数,分别是一个绑定IP与一个端口号。该示例使用0.0.0.0作为绑定地址(表示监听任何地址的Java约定)以及端口号12345。源配置还有一个名为channe