Sha256: 8ab81a32690beaa6a23f4b38f6c27428aa85e77cb33847ce0882dc15c851567a
Contents?: true
Size: 592 Bytes
Versions: 5
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
5 entries across 5 versions & 1 rubygems