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