Module: FFWD::Plugin::Kafka::HostPartitioner

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

Overview

Use the host for partitioning.

Class Method Summary collapse

Class Method Details

.partition(d) ⇒ Object 



26
27
28
 
# File 'lib/ffwd/plugin/kafka/partitioners.rb', line 26

def self.partition d
  d.host
end