# frozen_string_literal: true 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 [Integer] 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