Sha256: c97fb3d80fbbd83df1cc2fa93e8e20f7bf843e7e778ab113e8044923f8c175c2
Contents?: true
Size: 791 Bytes
Versions: 20
Compression:
Stored size: 791 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.
# @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
Version data entries
20 entries across 20 versions & 2 rubygems