lib/karafka/instrumentation/notifications.rb in karafka-2.0.1 vs lib/karafka/instrumentation/notifications.rb in karafka-2.0.2

- old
+ new

@@ -32,9 +32,10 @@ connection.listener.fetch_loop connection.listener.fetch_loop.received worker.process worker.processed + worker.completed statistics.emitted error.occurred ].freeze