class

Kafka::Consumer::Rebalance

Inherits Reference / Object

Class methods

callback

Returns a callback to be used when partitions are assigned/unassigned.

This will log the assignment event with the topic name and partition number. Calls the rd_kafka_assign C function.

Source