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