misha_cafex v0.0.6 Cafex.Consumer.GroupManager.Kafka

The implementation of Kafka Client-side Assignment Proposal

Supported Kafka 0.9.x or above.

See Kafka Client-side Assignment Proposal to read more.

Summary

Functions

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

stop(pid)

Functions

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

stop(pid)