module FFWD::Plugin::Kafka::HostPartitioner
Use the host for partitioning.
Public Class Methods
partition(d)
click to toggle source
# File lib/ffwd/plugin/kafka/partitioners.rb, line 26 def self.partition d d.host end