View Source Kayrock.Convenience (kayrock v0.2.0)

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

Link to this function

get_partition_leaders(client_pid, topic)

View Source
Link to this function

partition_last_offset(client_pid, topic, partition)

View Source
Link to this function

partitions_last_offset(client_pid, topic, partitions)

View Source

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

Link to this function

topic_exists?(pid, topic)

View Source
Link to this function

topic_last_offsets(client_pid, topic)

View Source