RdKafka

abstract class RdKafka (View source)

Methods

int
addBrokers(string $broker_list)

No description

Metadata
getMetadata(bool $all_topics, null|Topic $only_topic = null, int $timeout_ms = 0)

No description

int
getOutQLen()

No description

Topic
newTopic(string $topic_name, null|TopicConf $topic_conf = null)

No description

void
poll(int $timeout_ms)

No description

void
setLogLevel(int $level)

No description

TopicPartition[]
offsetsForTimes(TopicPartition[] $topic_partitions, int $timeout_ms)

No description

void
queryWatermarkOffsets(string $topic, int $partition = 0, int $low = 0, int $high = 0, int $timeout_ms = 0)

No description

int
purge(int $purge_flags)

No description

int
flush(int $timeout_ms)

No description

metadata($all_topics, $only_topic = false, $timeout_ms = 0)

No description

setLogger($logger)

No description

outqLen()

No description

Details

at line 16
int addBrokers(string $broker_list)

No description

Parameters

string $broker_list

Return Value

int

at line 26
Metadata getMetadata(bool $all_topics, null|Topic $only_topic = null, int $timeout_ms = 0)

No description

Parameters

bool $all_topics
null|Topic $only_topic
int $timeout_ms

Return Value

Metadata

Exceptions

Exception

at line 31
int getOutQLen()

No description

Return Value

int

at line 39
Topic newTopic(string $topic_name, null|TopicConf $topic_conf = null)

No description

Parameters

string $topic_name
null|TopicConf $topic_conf

Return Value

Topic

at line 46
void poll(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

void

at line 53
void setLogLevel(int $level)

No description

Parameters

int $level

Return Value

void

at line 61
TopicPartition[] offsetsForTimes(TopicPartition[] $topic_partitions, int $timeout_ms)

No description

Parameters

TopicPartition[] $topic_partitions
int $timeout_ms

Return Value

TopicPartition[]

at line 72
void queryWatermarkOffsets(string $topic, int $partition = 0, int $low = 0, int $high = 0, int $timeout_ms = 0)

No description

Parameters

string $topic
int $partition
int $low
int $high
int $timeout_ms

Return Value

void

at line 79
int purge(int $purge_flags)

No description

Parameters

int $purge_flags

Return Value

int

at line 86
int flush(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

int

at line 88
metadata($all_topics, $only_topic = false, $timeout_ms = 0)

No description

Parameters

$all_topics
$only_topic
$timeout_ms

at line 90
setLogger($logger)

No description

Parameters

$logger

at line 92
outqLen()

No description