lib/karafka/instrumentation/notifications.rb in karafka-2.2.12 vs lib/karafka/instrumentation/notifications.rb in karafka-2.2.13

- old
+ new

@@ -41,9 +41,10 @@ rebalance.partitions_assign rebalance.partitions_assigned rebalance.partitions_revoke rebalance.partitions_revoked + consumer.before_enqueue consumer.consume consumer.consumed consumer.consuming.pause consumer.consuming.retry consumer.idle