Remove set_security_user processor configs to make all unsupported processors same behavior.

Author: mashhurs

spec/integration/elastic_integration_spec.rb

@@ -1481,4 +1481,61 @@ def path; @path; end
     end
   end
 
+  context '#unsupported processors' do
+    let(:settings) {
+      super().merge(
+        "ssl_certificate_authorities" => "spec/fixtures/test_certs/root.crt"
+      )
+    }
+
+    unsupported_processors = {
+      'set_security_user' =>
+        '{
+            "set_security_user": {
+                "field": "user"
+             }
+        }',
+      'inference' =>
+        '{
+            "inference": {
+                "model_id": "model_deployment_for_inference",
+                "input_output": [{"input_field": "content", "output_field": "content_embedding"}]
+            }
+        }',
+      'enrich' =>
+        '{
+            "enrich": {
+                "policy_name": "enrich_policy_name",
+                "field": "source_field",
+                "target_field": "target_field"
+            }
+         }'
+    }
+
+    before(:each) do
+      subject.register
+    end
+
+    shared_examples 'processor failure' do
+      it 'adds failure tag to metadata' do
+        events = [LogStash::Event.new(
+          "message" => "55.3.244.1 GET /index.html 15824 0.043",
+          "data_stream" => data_stream
+        )]
+
+        subject.multi_filter(events).each do |event|
+          failure_reason = event.get("[@metadata][_ingest_pipeline_failure]")
+          expect(failure_reason).to be_truthy
+        end
+      end
+    end
+
+    unsupported_processors.each do |name, config|
+      describe "with #{name} processor" do
+        let(:pipeline_processor) { config }
+        include_examples 'processor failure'
+      end
+    end
+  end
+
 end

src/main/java/co/elastic/logstash/filters/elasticintegration/EventProcessorBuilder.java

@@ -9,7 +9,6 @@
 import co.elastic.logstash.api.Event;
 import co.elastic.logstash.api.FilterMatchListener;
 import co.elastic.logstash.filters.elasticintegration.ingest.RedactPlugin;
-import co.elastic.logstash.filters.elasticintegration.ingest.SetSecurityUserProcessor;
 import co.elastic.logstash.filters.elasticintegration.ingest.SingleProcessorIngestPlugin;
 import co.elastic.logstash.filters.elasticintegration.resolver.CacheReloadService;
 import co.elastic.logstash.filters.elasticintegration.resolver.CachingResolver;
@@ -33,7 +32,6 @@
 import org.elasticsearch.painless.PainlessPlugin;
 import org.elasticsearch.painless.PainlessScriptEngine;
 import org.elasticsearch.painless.spi.PainlessExtension;
-import org.elasticsearch.painless.spi.Whitelist;
 import org.elasticsearch.plugins.ExtensiblePlugin;
 import org.elasticsearch.plugins.IngestPlugin;
 import org.elasticsearch.script.IngestConditionalScript;
@@ -128,7 +126,6 @@ public EventProcessorBuilder() {
                 org.elasticsearch.ingest.common.UriPartsProcessor.TYPE));
         this.addProcessorsFromPlugin(IngestUserAgentPlugin::new);
         this.addProcessorsFromPlugin(RedactPlugin::new);
-        this.addProcessor(SetSecurityUserProcessor.TYPE, SetSecurityUserProcessor.Factory::new);
     }
 
     // event -> pipeline name