Contents

require "zlib"

module Kafka
  class Partitioner
    def initialize(partitions)
      @partitions = partitions
    end

    def partition_for_key(key)
      Zlib.crc32(key) % @partitions.count
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
ruby-kafka-0.1.0.pre.beta1	lib/kafka/partitioner.rb