Method: Rdkafka::Admin::CreateTopicHandle#raise_error

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

#raise_error ⇒ Object

Raises:

[View source] [View on GitHub]

21
22
23
24
25
26
 
# File 'lib/rdkafka/admin/create_topic_handle.rb', line 21

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