class
Kafka::Consumer::Rebalance
- Kafka::Consumer::Rebalance
- Reference
- Object
Defined in:
kafka/consumer/rebalance.crClass Method Summary
-
.callback
Returns a callback to be used when partitions are assigned/unassigned.
Class Method Detail
def self.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.