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