Skip to content

Class TopicPartitionList

Class \RdKafka\TopicPartitionList

  • implements \Iterator
  • implements \Countable

Methods

__construct()

public __construct ( 
    \RdKafka\TopicPartition[] $items
 ): 
Parameters
items \RdKafka\TopicPartition[]

asArray()

public asArray (  ): \RdKafka\TopicPartition[]
Returns
\RdKafka\TopicPartition[]

count()

public count (  ): int
Returns
int

current()

public current (  ): \RdKafka\TopicPartition
Returns
\RdKafka\TopicPartition

fromCData()

public static fromCData ( 
    \FFI\CData $topicPartitionList
 ): self
Parameters
topicPartitionList \FFI\CData
Returns
self

getCData()

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

key()

public key (  ): int
Returns
int

next()

public next (  ): void

rewind()

public rewind (  ): void

valid()

public valid (  ): bool
Returns
bool

Test Coverage 💚

  • 💚 Lines: 96.3% (26 / 27)
  • 💛 Methods: 90% (9 / 10)