lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.8 vs lib/fluent/plugin/out_kafka.rb in fluent-plugin-kafka-enchanced-0.5.9
- old
+ new
@@ -70,10 +70,9 @@
super
require 'kafka'
require "avro_turf"
require "avro/builder"
- require 'avro-schema-registry'
@kafka = nil
end
def refresh_client