Class RebalanceCallbackProxy

Class \RdKafka\FFI\RebalanceCallbackProxy

• extends \RdKafka\FFI\CallbackProxy

Methods

__invoke()

public __invoke ( 
    \FFI\CData $consumer, 
    int $err, 
    \FFI\CData $nativeTopicPartitionList, 
    ?\FFI\CData $opaque = null
 ): void

Parameters

consumer \FFI\CData

err int

nativeTopicPartitionList \FFI\CData

opaque ?\FFI\CData

Test Coverage 💛

• 💛 Lines: 75% (6 / 8)
• ❤️ Methods: 0% (0 / 1)