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

      # The name of the topic this message was produced to.
      # @return [String]
      attr_reader :topic_name

      # Error in case happen during produce.
      # @return [String]
      attr_reader :error

      private

      def initialize(partition, offset, topic_name = nil, error = nil)
        @partition = partition
        @offset = offset
        @topic_name = topic_name
        @error = error
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
karafka-rdkafka-0.12.4	lib/rdkafka/producer/delivery_report.rb
karafka-rdkafka-0.12.3	lib/rdkafka/producer/delivery_report.rb