Class: Rdkafka::Producer::DeliveryReport

Inherits:
Object
  • Object
show all
Defined in:
lib/rdkafka/producer/delivery_report.rb

Overview

Delivery report for a successfully produced message.

Instance Attribute Summary collapse

Instance Attribute Details

#errorInteger (readonly)

Error in case happen during produce.

Returns:

  • (Integer)


22
23
24
# File 'lib/rdkafka/producer/delivery_report.rb', line 22

def error
  @error
end

#labelObject? (readonly)

Returns label set during message production or nil by default.

Returns:

  • (Object, nil)

    label set during message production or nil by default



25
26
27
# File 'lib/rdkafka/producer/delivery_report.rb', line 25

def label
  @label
end

#offsetInteger (readonly)

The offset of the produced message.

Returns:

  • (Integer)


13
14
15
# File 'lib/rdkafka/producer/delivery_report.rb', line 13

def offset
  @offset
end

#partitionInteger (readonly)

The partition this message was produced to.

Returns:

  • (Integer)


9
10
11
# File 'lib/rdkafka/producer/delivery_report.rb', line 9

def partition
  @partition
end

#topic_nameString? (readonly) Also known as: topic

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

Returns:

  • (String, nil)


18
19
20
# File 'lib/rdkafka/producer/delivery_report.rb', line 18

def topic_name
  @topic_name
end