misha_cafex v0.0.6 Cafex.Consumer.OffsetManager

Summary

Functions

commit(pid, partition, offset, metadata \\ "")

fetch(pid, partition, leader_conn)

reset(pid, partition, leader_conn)

start_link(coordinator, partitions, group, topic, opts \\ [])

stop(pid)

update_generation_id(pid, consumer_id, generation_id)

Functions

commit(pid, partition, offset, metadata \\ "")

fetch(pid, partition, leader_conn)

reset(pid, partition, leader_conn)

start_link(coordinator, partitions, group, topic, opts \\ [])

stop(pid)

update_generation_id(pid, consumer_id, generation_id)