module FFWD::Plugin::Kafka::KeyPartitioner

Use the key for partitioning.

Public Class Methods

partition(d) click to toggle source
# File lib/ffwd/plugin/kafka/partitioners.rb, line 19
def self.partition d
  d.key
end