diff --git a/loggers/tcpclient.go b/loggers/tcpclient.go index b4024b34..30535d8a 100644 --- a/loggers/tcpclient.go +++ b/loggers/tcpclient.go @@ -306,7 +306,7 @@ func (o *TcpClient) Process() { bufferDm := []dnsutils.DnsMessage{} // init flust timer for buffer - flushInterval := time.Duration(o.config.Loggers.Fluentd.FlushInterval) * time.Second + flushInterval := time.Duration(o.config.Loggers.TcpClient.FlushInterval) * time.Second flushTimer := time.NewTimer(flushInterval) // init remote conn