diff --git a/lib/fluent/plugin/in_systemd.rb b/lib/fluent/plugin/in_systemd.rb index 4a18413..b991e46 100644 --- a/lib/fluent/plugin/in_systemd.rb +++ b/lib/fluent/plugin/in_systemd.rb @@ -132,6 +132,8 @@ def formatted(entry) def watch(&block) yield_current_entry(&block) while @journal.move_next + rescue Systemd::JournalError => e + log.warn("Error moving to next Journal entry: #{e.class}: #{e.message}") end def yield_current_entry