Skip to content

Class NewPartitions

Class \RdKafka\Admin\NewPartitions

Methods

__construct()

public __construct ( 
    string $topicName, 
    int $new_total_cnt
 ): 
Parameters
topicName string
new_total_cnt int

__destruct()

public __destruct (  ): 

getCData()

public getCData (  ): \FFI\CData
Returns
\FFI\CData

setReplicaAssignment()

public setReplicaAssignment ( 
    int $new_partition_id, 
    int[] $broker_ids
 ): void
Parameters
new_partition_id int
broker_ids int[]

Test Coverage 💚

  • 💚 Lines: 91.89% (34 / 37)
  • ❤️ Methods: 25% (1 / 4)