Flume的sink

Flume的sink

  console[("format")] :直接将将数据显示在consolr上。

  text(“txtfile”):将数据写到文件txtfile中。

  dfs(“dfsfile”):将数据写到HDFS上的dfsfile文件中。

  syslogTcp(“host”,port):将数据通过TCP传递给host节点。

  agentSink[("machine"[,port])]:等价于agentE2ESink,如果省略,machine参数,默认使用 flume.collector.event.host与flume.collector.event.port作为默认collecotr。

  agentDFOSink[("machine" [,port])]:本地热备agent,agent发现collector节点故障后,不断检查collector的存活状态以便重新发送event,在此间产生的数据将缓存到本地磁盘中。

  agentBESink[("machine"[,port])]:不负责的agent,如果collector故障,将不做任何处理,它发送的数据也将被直接丢弃。

  agentE2EChain:指定多个collector提高可用性。 当向主collector发送event失效后,转向第二个collector发送,当所有的collector失败后,它会非常执着的再来一遍。

原文地址:https://www.cnblogs.com/zlslch/p/6784958.html