Class: Kafka::FFI::GroupList

Inherits:

FFI::Struct

• Object
• FFI::Struct
• Kafka::FFI::GroupList

Defined in:

lib/kafka/ffi/group_list.rb

Instance Method Summary

• #destroy ⇒ Object

  Release the resources used by the group list back to the system.

• #groups ⇒ Array<GroupInfo>

  Returns information about the consumer groups in the cluster.

Instance Method Details

#destroy ⇒ Object

Release the resources used by the group list back to the system

# File 'lib/kafka/ffi/group_list.rb', line 23

def destroy
  ::Kafka::FFI.rd_kafka_group_list_destroy(self)
end

#groups ⇒ Array<GroupInfo>

Returns information about the consumer groups in the cluster.

Returns:

• (Array<GroupInfo>) —

  Group metadata

# File 'lib/kafka/ffi/group_list.rb', line 16

def groups
  self[:group_cnt].times.map do |i|
    GroupInfo.new(self[:groups] + (i * GroupInfo.size))
  end
end