Kayrock.Convenience (kayrock v1.0.1)

Copy Markdown View Source

Convenience functions for working with Kayrock / Kafka API data

Summary

Functions

get_partition_leaders(client_pid, topic)
partition_last_offset(client_pid, topic, partition)
partitions_last_offset(client_pid, topic, partitions)

Returns a map of partition to offset for partitions on the same leader

topic_exists?(pid, topic)
topic_last_offsets(client_pid, topic)

Functions

get_partition_leaders(client_pid, topic)

partition_last_offset(client_pid, topic, partition)

partitions_last_offset(client_pid, topic, partitions)

Returns a map of partition to offset for partitions on the same leader

All partitions must be on the same leader or you will get -1 for the offset

topic_exists?(pid, topic)

topic_last_offsets(client_pid, topic)