diff --git a/lib/fluent/plugin/filter_kubernetes_metadata.rb b/lib/fluent/plugin/filter_kubernetes_metadata.rb
index <HASH>..<HASH> 100644
--- a/lib/fluent/plugin/filter_kubernetes_metadata.rb
+++ b/lib/fluent/plugin/filter_kubernetes_metadata.rb
@@ -196,8 +196,8 @@ module Fluent
       end
 
     end
-    
-    def filter(tag, time, record)
+
+    def filter_stream(tag, es)
       record
     end
Define filter_stream instead of filter