Class: Rdkafka::Admin::CreatePartitionsHandle

Inherits:
Rdkafka::AbstractHandle show all
Defined in:
lib/rdkafka/admin/create_partitions_handle.rb

Overview

Handle for create partitions operation

Constant Summary

Constants inherited from Rdkafka::AbstractHandle

Rdkafka::AbstractHandle::REGISTRY

Instance Method Summary collapse

Methods inherited from Rdkafka::AbstractHandle

#initialize, #pending?, register, remove, #unlock, #wait

Methods included from Helpers::Time

#monotonic_now

Constructor Details

This class inherits a constructor from Rdkafka::AbstractHandle

Instance Method Details

#create_result ⇒ Boolean

Returns whether the create topic was successful.

Returns:

  • (Boolean) —

    whether the create topic was successful



16
17
18
 
# File 'lib/rdkafka/admin/create_partitions_handle.rb', line 16

def create_result
  CreatePartitionsReport.new(self[:error_string], self[:result_name])
end

#operation_name ⇒ String

Returns the name of the operation.

Returns:

  • (String) —

    the name of the operation



11
12
13
 
# File 'lib/rdkafka/admin/create_partitions_handle.rb', line 11

def operation_name
  "create partitions"
end

#raise_error ⇒ Object

Raises an error if the operation failed

Raises:



22
23
24
25
26
27
28
29
30
 
# File 'lib/rdkafka/admin/create_partitions_handle.rb', line 22

def raise_error
  RdkafkaError.validate!(
    self[:response],
    broker_message: CreatePartitionsReport.new(
      self[:error_string],
      self[:result_name]
    ).error_string
  )
end