Class PartitionerCallbackProxy

Class \RdKafka\FFI\PartitionerCallbackProxy

• extends \RdKafka\FFI\CallbackProxy

Methods

__invoke()

public __invoke ( 
    ?\FFI\CData $topic, 
    ?\FFI\CData $keydata, 
    int $keylen, 
    int $partition_cnt, 
    ?\FFI\CData $topic_opaque = null, 
    ?\FFI\CData $msg_opaque = null
 ): int

Parameters

topic ?\FFI\CData

keydata ?\FFI\CData

keylen int

partition_cnt int

topic_opaque ?\FFI\CData

msg_opaque ?\FFI\CData

Returns

int

Test Coverage 🧡

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