satrushn

Thank you. Then after removing, how I must parse logs like this, field message: {"log":"2021-11-30 11:50:19.377 [INFO][39] int_dataplane.go 959: Applying dataplane updates\n","stream":"stdout","time":"2021-11-30T11:50:19.378077212Z"} ? Can you give an example please?

I added a filter: [PARSER] Name my-json Format json Time_Key time Time_Format %Y-%m-%dT%H:%M:%S.%L Time_Keep true And now I see in logs the same: message | {"log":"[2021/12/02 06:52:31] [ info] [storage]...

I use Kubernetes and input: [Input] Name tail Path /var/log/containers/.log Refresh_Interval 10 Skip_Long_Lines true DB /fluent-bit/tail/pos.db DB.Sync Normal Mem_Buf_Limit 5MB Parser docker Tag kube. Information from tail of file is...

I also tried to use labels and I've got errors in fluentd log like: [error]: #0 failed to flush timeout buffer error_class=ArgumentError error="@NORMAL label not found" And there is no...

Thank you for your answer. I try to use Fluentd as Fluentd-operator, there is no way to change something in "source" that's why I want to use parser in filter....