Exception: Rdkafka::RdkafkaTopicPartitionListError

Inherits:

RdkafkaError

• Object
• RuntimeError
• BaseError
• RdkafkaError
• Rdkafka::RdkafkaTopicPartitionListError

Defined in:

lib/rdkafka/error.rb

Overview

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

Constant Summary

Constants inherited from RdkafkaError

Rdkafka::RdkafkaError::EMPTY_HASH

Instance Attribute Summary

• #topic_partition_list ⇒ TopicPartitionList readonly

Attributes inherited from RdkafkaError

#broker_message, #details, #message_prefix, #rdkafka_response

Instance Method Summary

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

  A new instance of RdkafkaTopicPartitionListError.

Methods inherited from RdkafkaError

#==, #abortable?, build, build_fatal, build_from_c, #code, #fatal?, #is_partition_eof?, #retryable?, #to_s, validate!

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

# File 'lib/rdkafka/error.rb', line 250

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)

# File 'lib/rdkafka/error.rb', line 244

def topic_partition_list
  @topic_partition_list
end