Sha256: d1f209e482328b6b7d47a06aa5fff68001aa9bb0751f69c50e73e89f8423c765
Contents?: true
Size: 459 Bytes
Versions: 12
Compression:
Stored size: 459 Bytes
Contents
module Rdkafka
class Producer
# Delivery report for a succesfully 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
private
def initialize(partition, offset)
@partition = partition
@offset = offset
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems