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