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