Sha256: b7fee0870246edc9824d5c0900c3d3758506857fc33321684ad42d7f39d38ad0
Contents?: true
Size: 592 Bytes
Versions: 13
Compression:
Stored size: 592 Bytes
Contents
module Rdkafka
class Producer
# Delivery report for a successfully produced message.
class DeliveryReport
# The partition this message was produced to.
# @return [Integer]
attr_reader :partition
# 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, error = nil)
@partition = partition
@offset = offset
@error = error
end
end
end
end
Version data entries
13 entries across 13 versions & 2 rubygems