class Kafka::Consumer::Rebalance

Defined in:

kafka/consumer/rebalance.cr

Class 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.

[View source]