lib/kafka/producer.rb in ruby-kafka-0.6.0.beta4 vs lib/kafka/producer.rb in ruby-kafka-0.6.0

- old
+ new

@@ -1,4 +1,6 @@ +# frozen_string_literal: true + require "set" require "kafka/partitioner" require "kafka/message_buffer" require "kafka/produce_operation" require "kafka/pending_message_queue"