diff --git a/lib/fluent/plugin/in_beats.rb b/lib/fluent/plugin/in_beats.rb
index 11aa134..fd9937e 100644
--- a/lib/fluent/plugin/in_beats.rb
+++ b/lib/fluent/plugin/in_beats.rb
@@ -126,6 +126,7 @@ def run
           rescue => e
             log.error "unexpected error", :error => e.to_s
             log.error_backtrace
+            router.emit_error_event(tag, time, record, e)
           end
         }
       end