Points to personal ES repo which provides Stable API interface updates. Removes required upwrap interface since upstream moved to default method. Utilizes metadata version field since upstream made it accessible.

Author: mashhurs

gradle.properties

@@ -1,2 +1,3 @@
 LOGSTASH_PATH=../../logstash
-ELASTICSEARCH_TREEISH=main
+ELASTICSEARCH_REPO=mashhurs/elasticsearch
+ELASTICSEARCH_TREEISH=move-to-bridge-stable-api-investigation

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

@@ -198,13 +198,11 @@ private Set<Object> externalize(final @Nonnull Set<?> internalSet) {
      * @param event the event to fetch fallback values from
      */
     private void sanitizeIngestDocumentRequiredMetadataVersion(final Map<String,Object> sourceAndMetadata, final Event event) {
-        // TODO: make IngestDocument.Metadata.VERSION.getFieldName() available
-        Object sourceVersion = safeLongFrom(sourceAndMetadata.remove("_version"));
+        Object sourceVersion = safeLongFrom(sourceAndMetadata.remove(IngestDocumentBridge.Constants.METADATA_VERSION_FIELD_NAME));
         if (Objects.isNull(sourceVersion)) {
             sourceVersion = safeLongFrom(event.getField(org.logstash.Event.VERSION));
         }
-        // TODO: make IngestDocument.Metadata.VERSION.getFieldName() available
-        sourceAndMetadata.put("_version", Objects.requireNonNullElse(sourceVersion, 1L));
+        sourceAndMetadata.put(IngestDocumentBridge.Constants.METADATA_VERSION_FIELD_NAME, Objects.requireNonNullElse(sourceVersion, 1L));
     }
 
     /**

src/main/java/co/elastic/logstash/filters/elasticintegration/ingest/PipelineProcessor.java

@@ -8,9 +8,6 @@
 
 import co.elastic.logstash.filters.elasticintegration.IngestPipeline;
 import co.elastic.logstash.filters.elasticintegration.IngestPipelineResolver;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
-import org.elasticsearch.ingest.Processor;
 import org.elasticsearch.logstashbridge.ingest.ConfigurationUtilsBridge;
 import org.elasticsearch.logstashbridge.ingest.IngestDocumentBridge;
 import org.elasticsearch.logstashbridge.ingest.ProcessorBridge;
@@ -31,8 +28,6 @@ public class PipelineProcessor implements ProcessorBridge {
     private final IngestPipelineResolver pipelineProvider;
     private final boolean ignoreMissingPipeline;
 
-    private static final Logger LOGGER = LogManager.getLogger(PipelineProcessor.class);
-
     private PipelineProcessor(String tag,
                               String description,
                               TemplateScriptBridge.Factory pipelineTemplate,
@@ -90,12 +85,6 @@ public void execute(IngestDocumentBridge ingestDocument, BiConsumer<IngestDocume
         }
     }
 
-    // TODO: find a way to remove this method
-    //  it is due to StableBridgeAPI#unwrap() requirement
-    @Override
-    public Processor unwrap() {
-        throw new RuntimeException("Unallowed operation.");
-    }
 
     public static class Factory implements ProcessorBridge.Factory {
 

src/main/java/co/elastic/logstash/filters/elasticintegration/ingest/SetSecurityUserProcessor.java

@@ -6,7 +6,6 @@
  */
 package co.elastic.logstash.filters.elasticintegration.ingest;
 
-import org.elasticsearch.ingest.Processor;
 import org.elasticsearch.logstashbridge.ingest.IngestDocumentBridge;
 import org.elasticsearch.logstashbridge.ingest.ProcessorBridge;
 
@@ -26,7 +25,7 @@ private SetSecurityUserProcessor(final String tag, final String description) {
 
 
     @Override
-    public void execute(IngestDocumentBridge ingestDocumentBridge, BiConsumer<IngestDocumentBridge, Exception> biConsumer) throws Exception {
+    public void execute(IngestDocumentBridge ingestDocumentBridge, BiConsumer<IngestDocumentBridge, Exception> biConsumer) {
         // within Logstash, the set_security_user processor is a no-op
     }
 
@@ -50,13 +49,6 @@ public boolean isAsync() {
         return false;
     }
 
-    // TODO: find a way to remove this method
-    //  it is due to StableBridgeAPI#unwrap() requirement
-    @Override
-    public Processor unwrap() {
-        return null;
-    }
-
     public static final class Factory implements ProcessorBridge.Factory {
 
         @Override