lib/karafka/instrumentation/notifications.rb in karafka-2.3.4 vs lib/karafka/instrumentation/notifications.rb in karafka-2.4.0.beta1

- old
+ new

@@ -38,10 +38,18 @@ connection.listener.before_fetch_loop connection.listener.fetch_loop connection.listener.fetch_loop.received connection.listener.after_fetch_loop + connection.listener.pending + connection.listener.starting + connection.listener.running + connection.listener.quieting + connection.listener.quiet + connection.listener.stopping + connection.listener.stopped + consumer.before_schedule_consume consumer.consume consumer.consumed consumer.consuming.pause consumer.consuming.retry @@ -63,9 +71,11 @@ dead_letter_queue.dispatched filtering.throttled filtering.seek + + oauthbearer.token_refresh process.notice_signal rebalance.partitions_assign rebalance.partitions_assigned