diff --git a/fluentd/logger.go b/fluentd/logger.go index cbbc309..4a33418 100644 --- a/fluentd/logger.go +++ b/fluentd/logger.go @@ -3,6 +3,7 @@ package fluentd import ( "fmt" "log" + "time" "github.com/fluent/fluent-logger-golang/fluent" ) @@ -14,9 +15,9 @@ type Logger struct { func NewLogger(appName, fHost string, fPort int) (*Logger, error) { config := fluent.Config{ - FluentHost: fHost, - FluentPort: fPort, - // WriteTimeout: -1, + FluentHost: fHost, + FluentPort: fPort, + WriteTimeout: 100 * time.Millisecond, } fluent, err := fluent.New(config) if err != nil {