require "fluent/plugin/filter" module Fluent module Plugin class GeovisFilter < Fluent::Plugin::Filter Fluent::Plugin.register_filter("geovis", self) def configure(conf) super puts "==================================FetchpodnameFilter configure" end def filter(tag, time, record) super puts "==================================FetchpodnameFilter filter" end end end end