Skip to content

Class RdKafka

abstract Class \RdKafka

Methods

__construct()

public __construct ( 
    int $type, 
    ?\RdKafka\Conf $conf = null
 ):
Parameters
type int
conf ?\RdKafka\Conf

__destruct()

public __destruct (  ):

getCData()

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

getMetadata()

public getMetadata ( 
    bool $all_topics, 
    ?\RdKafka\Topic $only_topic, 
    int $timeout_ms
 ): \RdKafka\Metadata
Parameters
all_topics bool
only_topic ?\RdKafka\Topic
timeout_ms int
Returns
\RdKafka\Metadata

getOpaque()

public getOpaque (  ): mixed|null
Returns
mixed|null

pausePartitions()

public pausePartitions ( 
    \TopicPartition[] $topicPartitions
 ): \TopicPartition[]
Parameters
topicPartitions \TopicPartition[]
Returns
\TopicPartition[]

queryWatermarkOffsets()

public queryWatermarkOffsets ( 
    string $topic, 
    int $partition, 
    int &$low, 
    int &$high, 
    int $timeout_ms
 ): void
Parameters
topic string
partition int
low int
high int
timeout_ms int

resolveFromCData()

public static resolveFromCData ( 
    ?\FFI\CData $kafka = null
 ): ?self
Parameters
kafka ?\FFI\CData
Returns
?self

resumePartitions()

public resumePartitions ( 
    \TopicPartition[] $topicPartitions
 ): \TopicPartition[]
Parameters
topicPartitions \TopicPartition[]
Returns
\TopicPartition[]

setLogLevel()

public setLogLevel ( 
    int $level
 ): void
Parameters
level int

Deprecated

Set via Conf parameter log_level instead

setLogger()

public setLogger ( 
    int $logger
 ): void
Parameters
logger int

Deprecated

Use Conf::setLogCb instead

Test Coverage 💛

  • 💛 Lines: 85.33% (64 / 75)
  • ❤️ Methods: 40% (6 / 15)

Extended by