lib/rdkafka/producer/delivery_report.rb in rdkafka-0.7.0 vs lib/rdkafka/producer/delivery_report.rb in rdkafka-0.8.0.beta.1

- old
+ new

@@ -8,14 +8,19 @@ # The offset of the produced message. # @return [Integer] attr_reader :offset + # Error in case happen during produce. + # @return [string] + attr_reader :error + private - def initialize(partition, offset) + def initialize(partition, offset, error = nil) @partition = partition @offset = offset + @error = error end end end end