Class ConsumeCallbackProxy

Class \RdKafka\FFI\ConsumeCallbackProxy

• extends \RdKafka\FFI\CallbackProxy

Methods

__invoke()

public __invoke ( 
    \FFI\CData $nativeMessage, 
    ?\FFI\CData $opaque = null
 ): void

Parameters

nativeMessage \FFI\CData

opaque ?\FFI\CData

Test Coverage 🧡

• 🧡 Lines: 66.67% (4 / 6)
• ❤️ Methods: 0% (0 / 1)