首页 > 解决方案 > fluentd 输入 in_udp 并输出到 tcp

问题描述

我在 fluentd 中有一个 udp 输入:

<source> # mylog
  @type udp
  port 41234
  tag json
  <parse>
    @type none
  </parse>
</source>

我想通过一个 tcp 输出来传递它,因为我通过 haproxys 然后在一个 logstash 输入中。历史原因。

根据文档,我将它与@type forward 一起用于输出,所以我假设它转发udp。但后来在logstash方面,我在有效负载周围得到了一些额外的奇怪字符。logstash 配置:

input {
  tcp {
    host => "127.0.0.1"
    port => 41234
    codec => "json"
  }
}

你会怎么做?这甚至可能吗?

标签: tcpudplogstashfluentd

解决方案


推荐阅读