Sha256: 26076309bf6c4cd8e7129a39ac19d8e6b5c43e8959581808763b102017c94b74
Contents?: true
Size: 882 Bytes
Versions: 9
Compression:
Stored size: 882 Bytes
Contents
# 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 or nil in case delivery failed and we
# we not able to get the topic reference
# @return [String, nil]
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
Version data entries
9 entries across 9 versions & 1 rubygems