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