Skip to content

Class TopicPartition

Class \RdKafka\TopicPartition

Methods

__construct()

public __construct ( 
    string $topic, 
    int $partition, 
    int $offset, 
    string|null $metadata = null
 ): 
Parameters
topic string
partition int
offset int
metadata string|null requires librdkafka >= 1.2.0

fromCData()

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

getErr()

public getErr (  ): ?int
Returns
?int

getMetadata()

public getMetadata (  ): ?string
Returns
?string

getMetadataSize()

public getMetadataSize (  ): int
Returns
int

getOffset()

public getOffset (  ): int
Returns
int

getOpqaque()

public getOpqaque (  ): ?object
Returns
?object

getPartition()

public getPartition (  ): int
Returns
int

getTopic()

public getTopic (  ): string
Returns
string

setMetadata()

public setMetadata ( 
    ?string $metadata
 ): void
Parameters
metadata ?string

setOffset()

public setOffset ( 
    int $offset
 ): void
Parameters
offset int

setPartition()

public setPartition ( 
    int $partition
 ): void
Parameters
partition int

setTopic()

public setTopic ( 
    string $topic_name
 ): void
Parameters
topic_name string

Test Coverage 💚

  • 💚 Lines: 100% (30 / 30)
  • 💚 Methods: 100% (13 / 13)