diff --git a/internal/collector/otel_collector_plugin.go b/internal/collector/otel_collector_plugin.go index baf8255c8..c4899dc2d 100644 --- a/internal/collector/otel_collector_plugin.go +++ b/internal/collector/otel_collector_plugin.go @@ -492,14 +492,6 @@ func (oc *Collector) updateTcplogReceivers(nginxConfigContext *model.NginxConfig "protocol": "rfc3164", }, }, - { - Type: "key_value_parser", - Fields: map[string]string{ - "parse_from": "attributes.message", - "parse_to": "body", - "pair_delimiter": "\",\"", - }, - }, { Type: "remove", Fields: map[string]string{ diff --git a/internal/collector/otel_collector_plugin_test.go b/internal/collector/otel_collector_plugin_test.go index 28c76c386..67e5ecdd0 100644 --- a/internal/collector/otel_collector_plugin_test.go +++ b/internal/collector/otel_collector_plugin_test.go @@ -674,7 +674,7 @@ func TestCollector_updateTcplogReceivers(t *testing.T) { assert.True(tt, tcplogReceiverAdded) assert.Len(tt, conf.Collector.Receivers.TcplogReceivers, 1) assert.Equal(tt, "localhost:151", conf.Collector.Receivers.TcplogReceivers[0].ListenAddress) - assert.Len(tt, conf.Collector.Receivers.TcplogReceivers[0].Operators, 5) + assert.Len(tt, conf.Collector.Receivers.TcplogReceivers[0].Operators, 4) }) // Calling updateTcplogReceivers shouldn't update the TcplogReceivers slice @@ -684,7 +684,7 @@ func TestCollector_updateTcplogReceivers(t *testing.T) { assert.False(t, tcplogReceiverAdded) assert.Len(t, conf.Collector.Receivers.TcplogReceivers, 1) assert.Equal(t, "localhost:151", conf.Collector.Receivers.TcplogReceivers[0].ListenAddress) - assert.Len(t, conf.Collector.Receivers.TcplogReceivers[0].Operators, 5) + assert.Len(t, conf.Collector.Receivers.TcplogReceivers[0].Operators, 4) }) }