[フレーム]

Exception: Kafka::ProcessingError

Inherits:
Error
  • Object
  • StandardError
  • Error
  • Kafka::ProcessingError
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

AltStyle によって変換されたページ (->オリジナル) /