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();