带有 tcp 的 Logstash，错误：java.io.IOException：连接由对等方重置

Question

我想在我的 golangApp 中使用 logstash。

/etc/logstash/conf.d/first-pipeline.conf

input {

  tcp {

    port => 5959

    codec => json

  }

}

#filter {}

output {

    elasticsearch {

        hosts => [ "localhost:9200" ]

    }

}

和运行 logstash 的命令：

/usr/share/logstash/bin/logstash -f /etc/logstash/conf.d/first-pipeline.conf --path.settings=/etc/logstash

golang 中的代码：

import (

    "encoding/json"

    "fmt"

    "github.com/heatxsink/go-logstash"

    "time"

)

func main() {

l := logstash.New("0.0.0.0", 5959, 5)

_, err := l.Connect()

if err != nil {

    fmt.Println(err)

}

dataMap := map[string]int{"apple": 5, "lettuce": 7}

jsonMap, _ := json.Marshal(dataMap)

err = l.Writeln(string(jsonMap))

if err != nil {

    fmt.Println(err)

}

}

当我尝试在应用程序中请求 logstash 时，在终端显示此错误结束：

[2018-12-09T09:12:41,954][错误][logstash.inputs.tcp] Netty 管道错误：java.io.IOException：连接由对等方重置

每件事都在我的本地系统中。可以帮助我吗？

Answer 1

我在这个页面上找到了答案：https://github.com/logstash-plugins/logstash-input-tcp/issues/132