class

Kafka::TopicPartitionList

Inherits Reference < Object

A growable list of Topic+Partitions.

Constructors

new(rkparlist : LibKafka::TopicPartitionListT)
Source
new(size)

Create a new list/vector Topic+Partition container.

Source

Instance methods

add(topic : String, partition : Int32)

Add topic+partition to list.

Source
add_range(topic : String, start : Int32, stop : Int32)

Add range of partitions from start to stop inclusive.

Source
copy

Make a copy of an existing list.

Source
del(topic : String, partition : Int32)

Delete partition from list.

Source
del_by_idx(idx : LibC::Int)

Delete partition from list.

Source
destroy

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

Source
to_unsafe
Source
topic_partition_list_find(topic : String, partition : Int32)

Find element by topic and partition.

Source
topic_partition_list_set_offset(topic : String, partition : Int32, offset : Int64)

Set offset for topic and partition.

Source