lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.17.0 vs lib/fluent/plugin/in_kafka.rb in fluent-plugin-kafka-0.17.1

- old
+ new

@@ -69,9 +69,10 @@ def initialize super require 'kafka' @time_parser = nil + @zookeeper = nil end def configure(conf) super