delf.rb in logstash-input-delf-3.2

- old
+ new

@@ -38,10 +38,13 @@
   config :continue_mark_base64, :validate => :string, :default => "XA=="
 
   # The field to identify different event stream, for Docker events, it's 'container_id'
   config :track, :validate => :string, :default => 'container_id'
 
+  # max chars in a multi-line message
+  config :max_length, :validate => :number, :default => 10000
+
   RECONNECT_BACKOFF_SLEEP = 5
   TIMESTAMP_GELF_FIELD = "timestamp".freeze
   SOURCE_HOST_FIELD = "source_host".freeze
   MESSAGE_FIELD = "message"
   TAGS_FIELD = "tags"
@@ -219,10 +222,10 @@
         return nil
       else
         # append content to pending event
         last_event.set("message", last_event.get("message") + "\r\n" + message)
         # limit message length to 5000
-        if last_event.get("message").length > 5000
+        if last_event.get("message").length > @max_length
           @incomplete_events[track_id] = nil
           return last_event
         else
           return nil
         end