Sha256: 864ddc2e2f918fb587282d857d8d399304f482a696da9ffa2201bd2a3cc89570

Contents?: true

Size: 460 Bytes

Versions: 1

Compression:

Stored size: 460 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

      private

      def initialize(partition, offset)
        @partition = partition
        @offset = offset
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version Path
rdkafka-0.7.0 lib/rdkafka/producer/delivery_report.rb