lib/poseidon/consumer_group.rb
# Sorted partitions by broker address (so partitions on the same broker are clustered together)
# @return [Array<Poseidon::Protocol::PartitionMetadata>] sorted partitions
Sorted partitions by broker address (so partitions on the same broker are clustered together)
Sorted partitions by broker address ( so partitions on the same broker are clustered together )
def partitions
    return [] unless topic_metadata
    topic_metadata.available_partitions.sort_by do |part|
      broker = metadata.brokers[part.leader]
      [broker.host, broker.port].join(":")
    end
  end
def partitions return [ ] unless topic_metadata topic_metadata . available_partitions . sort_by do | part | broker = metadata . brokers [ part . leader ] [ broker . host , broker . port ] . join ( ":" ) end end
Sorted partitions by broker address (so partitions on the same broker are clustered together)
Sorted partitions by broker address ( so partitions on the same broker are clustered together )
None
Array<Poseidon::Protocol::PartitionMetadata>