Remove key_value_parser operator

nginx · Dec 3, 2024 · ddb02df · ddb02df
1 parent 29e07a0
commit ddb02df
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 10 deletions.
diff --git 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
@@ -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)
 	})
 }