Exception: Rdkafka::RdkafkaTopicPartitionListError

Inherits:
RdkafkaError show all
Defined in:
lib/rdkafka/error.rb

Overview

Error with topic partition list returned by the underlying rdkafka library.

Instance Attribute Summary collapse

Attributes inherited from RdkafkaError

#broker_message, #instance_name, #message_prefix, #rdkafka_response

Instance Method Summary collapse

Methods inherited from RdkafkaError

#==, #code, #is_partition_eof?, #to_s

Constructor Details

#initialize(response, topic_partition_list, message_prefix = nil) ⇒ RdkafkaTopicPartitionListError

Returns a new instance of RdkafkaTopicPartitionListError.

Parameters:

  • response (Integer) —

    the raw error response code from librdkafka

  • topic_partition_list (TopicPartitionList) —

    the topic partition list with error info

  • message_prefix (String, nil) (defaults to: nil) —

    optional prefix for error messages



88
89
90
91
 
# File 'lib/rdkafka/error.rb', line 88

def initialize(response, topic_partition_list, message_prefix = nil)
  super(response, message_prefix)
  @topic_partition_list = topic_partition_list
end

Instance Attribute Details

#topic_partition_list ⇒ TopicPartitionList (readonly)

Returns:

  • (TopicPartitionList) 


82
83
84
 
# File 'lib/rdkafka/error.rb', line 82

def topic_partition_list
  @topic_partition_list
end