Method: Kafka::RoundRobinAssignmentStrategy#valid_sorted_partitions

Defined in:
lib/kafka/round_robin_assignment_strategy.rb

#valid_sorted_partitions(members, partitions) ⇒ Object 



42
43
44
45
46
47
48
49
50
 
# File 'lib/kafka/round_robin_assignment_strategy.rb', line 42

def valid_sorted_partitions(members, partitions)
  subscribed_topics = members.map do |id, metadata|
    metadata && metadata.topics
  end.flatten.compact

  partitions
    .select { |partition| subscribed_topics.include?(partition.topic) }
    .sort_by { |partition| partition.topic }
end