Kaffe v1.9.0 Kaffe.GroupManager

This is the main process for launching group members and workers.

The process begins by starting the client connection to Kafka. Then, group members are created for each of the configured topics.

Summary

List of currently subscribed topics

Dynamically subscribe to topics in addition to the configured topics

list_subscribed_topics()

List of currently subscribed topics.

start_link()

subscribe_to_topics(topics)

Dynamically subscribe to topics in addition to the configured topics.

Returns the newly subscribed topics. This may not include all values topics if any are already subscribed to.