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

Version Path
rdkafka-0.10.0 lib/rdkafka/producer/delivery_report.rb
rdkafka-0.9.0 lib/rdkafka/producer/delivery_report.rb
rdkafka-0.8.1 lib/rdkafka/producer/delivery_report.rb
rdkafka-0.8.0 lib/rdkafka/producer/delivery_report.rb
rdkafka-0.8.0.beta.1 lib/rdkafka/producer/delivery_report.rb