Class NativePartitionerCallbackProxy

Class \RdKafka\FFI\NativePartitionerCallbackProxy

Methods

__construct()

public __construct ( 
    string $partitionerMethod
 ): 

Parameters

partitionerMethod string

__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

create()

public static create ( 
    string $partitionerMethod
 ): \Closure

Parameters

partitionerMethod string

Returns

\Closure

Test Coverage 💚

• 💚 Lines: 100% (11 / 11)
• 💚 Methods: 100% (3 / 3)