From bcfe56f32d7d21be746f24e50ab1f43f455ffb85 Mon Sep 17 00:00:00 2001
From: Kaise Cheng <kaise.cheng@elastic.co>
Date: Thu, 7 Nov 2024 17:04:16 +0000
Subject: [PATCH] set default pipelineBus to v1 fix: #16654

---
 .../main/java/org/logstash/plugins/pipeline/PipelineBus.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java b/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java
index 4a05bd80a7a..c80be2d283c 100644
--- a/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java
+++ b/logstash-core/src/main/java/org/logstash/plugins/pipeline/PipelineBus.java
@@ -43,7 +43,7 @@ public interface PipelineBus {
      * @return a new pipeline bus
      */
     static PipelineBus create() {
-        final String pipelineBusImplementation = System.getProperty("logstash.pipelinebus.implementation", "v2");
+        final String pipelineBusImplementation = System.getProperty("logstash.pipelinebus.implementation", "v1");
         switch (pipelineBusImplementation) {
             case "v1": return new PipelineBusV1();
             case "v2": return new PipelineBusV2();