diff --git a/lib/fluent/plugin/out_detect_exceptions.rb b/lib/fluent/plugin/out_detect_exceptions.rb index cca85d1..98c4785 100644 --- a/lib/fluent/plugin/out_detect_exceptions.rb +++ b/lib/fluent/plugin/out_detect_exceptions.rb @@ -41,6 +41,10 @@ class DetectExceptionsOutput < Output Fluent::Plugin.register_output('detect_exceptions', self) + def multi_workers_ready? + true + end + def configure(conf) super