notifications.rb in karafka-2.2.8.beta1

- old
+ new

@@ -33,12 +33,16 @@
 
         connection.listener.before_fetch_loop
         connection.listener.fetch_loop
         connection.listener.fetch_loop.received
 
-        connection.client.rebalance_callback
         connection.client.poll.error
         connection.client.unsubscribe.error
+
+        rebalance.partitions_assign
+        rebalance.partitions_assigned
+        rebalance.partitions_revoke
+        rebalance.partitions_revoked
 
         consumer.consume
         consumer.consumed
         consumer.consuming.pause
         consumer.consuming.retry