From 0e37bc27f8550b44f6b3ea8b32acc7ee38191f64 Mon Sep 17 00:00:00 2001
From: dmarkhas <minimizer@gmail.com>
Date: Wed, 18 Oct 2017 20:59:13 +0300
Subject: [PATCH 1/3] Update clone.rb

---
 lib/logstash/filters/clone.rb | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/logstash/filters/clone.rb b/lib/logstash/filters/clone.rb
index 056e076..2aa426b 100644
--- a/lib/logstash/filters/clone.rb
+++ b/lib/logstash/filters/clone.rb
@@ -14,6 +14,9 @@ class LogStash::Filters::Clone < LogStash::Filters::Base
 
   # A new clone will be created with the given type for each type in this list.
   config :clones, :validate => :array, :default => []
+  
+  # Optional configuration to specify field in which to store the clone type
+  config :clone_type_field, :validate => :string, :default = "type"
 
   public
   def register
@@ -24,7 +27,7 @@ def register
   def filter(event)
     @clones.each do |type|
       clone = event.clone
-      clone.set("type", type)
+      clone.set(@clone_type_field, type)
       filter_matched(clone)
       @logger.debug("Cloned event", :clone => clone, :event => event)
 

From d83d93df6eda41310b7c4fec7dff87c0892d6509 Mon Sep 17 00:00:00 2001
From: dmarkhas <minimizer@gmail.com>
Date: Wed, 18 Oct 2017 20:59:30 +0300
Subject: [PATCH 2/3] Update clone.rb

---
 lib/logstash/filters/clone.rb | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/logstash/filters/clone.rb b/lib/logstash/filters/clone.rb
index 2aa426b..e07440f 100644
--- a/lib/logstash/filters/clone.rb
+++ b/lib/logstash/filters/clone.rb
@@ -16,7 +16,7 @@ class LogStash::Filters::Clone < LogStash::Filters::Base
   config :clones, :validate => :array, :default => []
   
   # Optional configuration to specify field in which to store the clone type
-  config :clone_type_field, :validate => :string, :default = "type"
+  config :clone_type_field, :validate => :string, :default => "type"
 
   public
   def register

From 426f55e2b0e45d209b3c246b23d2f8ddc2efc5fd Mon Sep 17 00:00:00 2001
From: dmarkhas <minimizer@gmail.com>
Date: Wed, 18 Oct 2017 21:12:23 +0300
Subject: [PATCH 3/3] test for custom clone type field

---
 spec/filters/clone_spec.rb | 25 +++++++++++++++++++++++++
 1 file changed, 25 insertions(+)

diff --git a/spec/filters/clone_spec.rb b/spec/filters/clone_spec.rb
index af94193..a222ecc 100644
--- a/spec/filters/clone_spec.rb
+++ b/spec/filters/clone_spec.rb
@@ -29,6 +29,31 @@
     end
   end
 
+  describe "custom type field" do
+    config <<-CONFIG
+      filter {
+        clone {
+          clones => ["clone", "clone", "clone"]
+          clone_type_field => "custom_field"          
+        }
+      }
+    CONFIG
+
+    sample("message" => "hello world", "type" => "original") do
+      insist { subject }.is_a? Array
+      insist { subject.length } == 4
+      subject.each_with_index do |s,i|
+        if i == 0 # last one should be 'original'
+          insist { s.get("type") } == "original"
+        else
+          insist { s.get("type")} == "original"
+          insist { s.get("custom_field")} == "clone"
+        end
+        insist { s.get("message") } == "hello world"
+      end
+    end
+  end
+
   describe "Complex use" do
     config <<-CONFIG
       filter {