Method: FluQ::Input::Kafka#initialize

Defined in:: lib/fluq/input/kafka.rb

#initialize ⇒ `Kafka`

Constructor.

Examples:


FluQ::Input::Kafka.new handlers,
  topic: "page-views",
  group: "fluq",
  brokers: ["localhost:9092"],
  zookeepers: ["localhost:2181"]

Parameters:

options (Hash) —

a customizable set of options



29
30
31

# File 'lib/fluq/input/kafka.rb', line 29

def initialize(*)
  super
end