在Flume中使用Log4j2发送文本消息

耶稣·费尔南多·帕拉·佩雷斯

我有Log4j2配置:

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <appenders>

        <Console name="console" target="SYSTEM_OUT">
            <PatternLayout pattern="%d %-5p - %m%n"/>
        </Console>
      <Flume name="flume" >
            <MarkerFilter marker="FLUME" onMatch="ACCEPT" onMismatch="DENY"/>
            <Agent host="IP_HERE" port="6999"/>
      </Flume>
      <File name="file" fileName="flume.log">
            <MarkerFilter marker="FLUME" onMatch="ACCEPT" onMismatch="DENY"/>
        </File>      
    </appenders>

    <loggers>
        <root level="info">
            <appender-ref ref="file"/>
            <appender-ref ref="console"/>
         <appender-ref ref="flume"/>
        </root>

    </loggers>
</configuration>

和Flume代理:

agent1.channels = ch1
agent1.sources = avro-source1
agent1.sinks = hdfs-sink1

agent1.channels.ch1.type = memory

agent1.sources.avro-source1.type = avro
agent1.sources.avro-source1.bind = IP_HERE
agent1.sources.avro-source1.port = 6999

agent1.sinks.hdfs-sink1.type = hdfs
agent1.sinks.hdfs-sink1.hdfs.path = hdfs://hadoop/user/hduser/bond/flume
agent1.sinks.hdfs-sink1.hdfs.fileType = DataStream
agent1.sinks.hdfs-sink1.hdfs.writeFormat = Text


agent1.sinks.hdfs-sink1.channel = ch1
agent1.sources.avro-source1.channels = ch1

当我发送日志时,第一次进入Web服务器控制台时出现错误:“错误对附加器水槽的递归调用”,(水槽代理处于活动状态,并且它正确地进行了绑定过程)在下一个记录器事件中没有错误和一个文件是在hadoop上编写的,但是当我尝试使用HUE在“文本”模式下对其进行可视化时,我看不到已发送的文本,我只能看到二进制代码...有什么错误吗?还是我必须做些什么才能以文本模式写入文件?谢谢

耶稣·费尔南多·帕拉·佩雷斯

一样容易:

代替:

 <Flume name="flume" >

是:

<Flume name="flume" compress="false" type="Avro">

多亏一个好榜样

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

Spring Boot使用log4j2发送邮件

来自分类Dev

如何使用slf4j / log4j2发送电子邮件通知?

来自分类Dev

Log4j2计数消息

来自分类Dev

在Log4J2 YAML中使用属性

来自分类Dev

无法在quarkus中使用log4j2

来自分类Dev

在开发环境中使用Rails 4发送邮件

来自分类Dev

在log4j2中创建惰性消息

来自分类Dev

以log4j2模式限制最大消息大小

来自分类Dev

避免出现log4j2配置调试消息

来自分类Dev

如何使用 log4j2 将批量数据发送到 elasticsearch

来自分类Dev

使用facebook php sdk版本4发送消息的请求结构是什么?

来自分类Dev

使用facebook php sdk版本4发送消息的请求结构是什么?

来自分类Dev

使用log4j2的Spring Boot。配置log4j2 Spring查找

来自分类Dev

Azure功能:使用Log4j2配置Slf4j绑定并将日志发送到appinsights

来自分类Dev

如何在ActiveMQ中使用log4j2 JMSAppender

来自分类Dev

在Spring Boot应用中使用log4j2进行日志记录

来自分类Dev

如何在ActiveMQ中使用log4j2 JMSAppender

来自分类Dev

Spring Boot 在 Eclipse 中使用 log4j2 - NoClassDefFoundError Logback

来自分类Dev

使用单个log4j2 xml文件配置log4j2和log4j

来自分类Dev

使用libnl-3发送Netlink Taskstats消息

来自分类Dev

使用RFC5424格式的log4j2和syslog不显示日志消息的varargs部分

来自分类Dev

无法使用 Log4j2 在控制台中记录消息,但它们被记录在文件中

来自分类Dev

log4J2 EventLogger使用Level.OFF

来自分类Dev

如何使用Log4j2登录关机钩子?

来自分类Dev

如何使用log4j2 Commons Logging Bridge

来自分类Dev

使用ConfigurationFactory以编程方式配置log4j2

来自分类Dev

使用log4j2,如何记录键值对

来自分类Dev

使用HashMap登录log4j2的正确方法

来自分类Dev

使用XMLLayout的log4j2如何?

Related 相关文章

热门标签

归档