lib/karafka/connection/rebalance_manager.rb in karafka-2.0.11 vs lib/karafka/connection/rebalance_manager.rb in karafka-2.0.12
- old
+ new
@@ -12,9 +12,12 @@
#
# @note Internally in the rebalance manager we have a notion of lost partitions. Partitions
# that are lost, are those that got revoked but did not get re-assigned back. We do not
# expose this concept outside and we normalize to have them revoked, as it is irrelevant
# from the rest of the code perspective as only those that are lost are truly revoked.
+ #
+ # @note For cooperative-sticky `#assigned_partitions` holds only the recently assigned
+ # partitions, not all the partitions that are owned
class RebalanceManager
# Empty array for internal usage not to create new objects
EMPTY_ARRAY = [].freeze
attr_reader :assigned_partitions, :revoked_partitions