Module: FFWD::Plugin::Kafka::KeyPartitioner

Defined in:
lib/ffwd/plugin/kafka/partitioners.rb

Overview

Use the key for partitioning.

Class Method Summary collapse

Class Method Details

.partition(d) ⇒ Object 



19
20
21
 
# File 'lib/ffwd/plugin/kafka/partitioners.rb', line 19

def self.partition d
  d.key
end