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

Question

我想在我的 golangApp 中使用 logstash。/etc/logstash/conf.d/first-pipeline.confinput {  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/logstashgolang 中的代码：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：连接由对等方重置每件事都在我的本地系统中。可以帮助我吗？