Class: Rdkafka::Admin::DeleteGroupsHandle

Inherits:

Rdkafka::AbstractHandle

• Object
• FFI::Struct
• Rdkafka::AbstractHandle
• Rdkafka::Admin::DeleteGroupsHandle

Defined in:

lib/rdkafka/admin/delete_groups_handle.rb

Overview

Handle for delete groups operation

Constant Summary

Constants inherited from Rdkafka::AbstractHandle

Rdkafka::AbstractHandle::REGISTRY

Instance Attribute Summary

Attributes inherited from Rdkafka::AbstractHandle

#broker_message, #result

Instance Method Summary

• #operation_name ⇒ String

  The name of the operation.

• #raise_error ⇒ Object

  Raises an error if the operation failed.

Methods inherited from Rdkafka::AbstractHandle

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

Methods included from Helpers::Time

#monotonic_now, #monotonic_now_ms

Constructor Details

This class inherits a constructor from Rdkafka::AbstractHandle

Instance Method Details

#operation_name ⇒ String

Returns the name of the operation.

Returns:

• (String) —

  the name of the operation

# File 'lib/rdkafka/admin/delete_groups_handle.rb', line 11

def operation_name
  "delete groups"
end

#raise_error ⇒ Object

Raises an error if the operation failed

Raises:

• (RdkafkaError)

# File 'lib/rdkafka/admin/delete_groups_handle.rb', line 17

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