Exception: Kafka::ProcessingError

Inherits:
Error
  • Object
show all
Defined in:
lib/kafka.rb

Overview

There was an error processing a message.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topic, partition, offset) ⇒ ProcessingError

Returns a new instance of ProcessingError


13
14
15
16
17
18
19
# File 'lib/kafka.rb', line 13

def initialize(topic, partition, offset)
  @topic = topic
  @partition = partition
  @offset = offset

  super()
end

Instance Attribute Details

#offsetObject (readonly)

Returns the value of attribute offset


11
12
13
# File 'lib/kafka.rb', line 11

def offset
  @offset
end

#partitionObject (readonly)

Returns the value of attribute partition


11
12
13
# File 'lib/kafka.rb', line 11

def partition
  @partition
end

#topicObject (readonly)

Returns the value of attribute topic


11
12
13
# File 'lib/kafka.rb', line 11

def topic
  @topic
end