class Kafka::TopicPartitionList

• Kafka::TopicPartitionList
• Reference
• Object

Overview

A growable list of Topic+Partitions.

Defined in:

kafka/topic_partition_list.cr

Constructors

• .new(rkparlist : LibKafka::TopicPartitionListT)
• .new(size)

  Create a new list/vector Topic+Partition container.

Instance Method Summary

• #add(topic : String, partition : Int32)

  Add topic+partition to list.

• #add_range(topic : String, start : Int32, stop : Int32)

  Add range of partitions from start to stop inclusive.

• #copy : TopicPartitionList

  Make a copy of an existing list.

• #del(topic : String, partition : Int32)

  Delete partition from list.

• #del_by_idx(idx : LibC::Int)

  Delete partition from list.

• #destroy

  Free all resources used by the list and the list itself.

• #to_unsafe : LibKafka::TopicPartitionListT | Pointer(LibKafka::TopicPartitionListT)
• #topic_partition_list_find(topic : String, partition : Int32)

  Find element by topic and partition.

• #topic_partition_list_set_offset(topic : String, partition : Int32, offset : Int64)

  Set offset for topic and partition.

Constructor Detail

Instance Method Detail