Skip to content

Class RebalanceCallbackProxy

Class \RdKafka\FFI\RebalanceCallbackProxy

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: 100% (6 / 6)
  • 💚 Methods: 100% (1 / 1)