Method: Rdkafka::Admin::CreatePartitionsHandle#raise_error

Defined in:
lib/rdkafka/admin/create_partitions_handle.rb

#raise_error ⇒ Object

Raises:

[View source] [View on GitHub]

19
20
21
22
23
24
 
# File 'lib/rdkafka/admin/create_partitions_handle.rb', line 19

def raise_error
  raise RdkafkaError.new(
      self[:response],
      broker_message: CreateTopicReport.new(self[:error_string], self[:result_name]).error_string
  )
end