max_id.rb

require "logstash/filters/base"
require "logstash/namespace"

class LogStash::Filters::MaxID < LogStash::Filters::Base
  @@max_id = 1
  config_name "max_id"
  plugin_status "experimental"

  public

  def filter(event)
    return unless filter?(event)
    @@max_id = @@max_id + 1
    event["max_id"] = @@max_id
    filter_matched(event)
  end # def filter
end # class LogStash::Filters::MaxID