1. class
  2. RdKafka
  3. \
  4. Producer

Producer

class Producer extends RdKafka (View source)

Methods

int
addBrokers(string $broker_list)

No description

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

No description

from  RdKafka
getControllerId(int $timeout_ms)

No description

from  RdKafka
int
getOutQLen()

No description

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

No description

void
poll(int $timeout_ms)

No description

from  RdKafka
void
setLogLevel(int $level)

No description

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

No description

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

No description

from  RdKafka
int
purge(int $purge_flags)

No description

from  RdKafka
int
flush(int $timeout_ms)

No description

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

No description

from  RdKafka
setLogger($logger)

No description

from  RdKafka
outqLen()

No description

from  RdKafka
pausePartitions(array $topic_partitions)

No description

from  RdKafka
resumePartitions(array $topic_partitions)

No description

from  RdKafka
oauthbearerSetToken(string $token_value, int|float|string $lifetime_ms, string $principal_name, array $extensions = [])

No description

from  RdKafka
oauthbearerSetTokenFailure(string $error)

No description

from  RdKafka
__construct(null|Conf $conf = null)

No description

void
initTransactions(int $timeout_ms)

No description

void
beginTransaction()

No description

void
commitTransaction(int $timeout_ms)

No description

void
abortTransaction(int $timeout_ms)

No description

Details

in RdKafka at line 30
int addBrokers(string $broker_list)

No description

Parameters

string $broker_list

Return Value

int

in RdKafka at line 40
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

in RdKafka at line 42
getControllerId(int $timeout_ms)

No description

Parameters

int $timeout_ms

in RdKafka at line 49
int getOutQLen()

No description

Return Value

int

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

No description

Parameters

string $topic_name
null|TopicConf $topic_conf

Return Value

Topic

in RdKafka at line 64
void poll(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

void

in RdKafka at line 71
void setLogLevel(int $level)

No description

Parameters

int $level

Return Value

void

in RdKafka at line 79
TopicPartition[] offsetsForTimes(TopicPartition[] $topic_partitions, int $timeout_ms)

No description

Parameters

TopicPartition[] $topic_partitions
int $timeout_ms

Return Value

TopicPartition[]

in RdKafka at line 90
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

in RdKafka at line 97
int purge(int $purge_flags)

No description

Parameters

int $purge_flags

Return Value

int

in RdKafka at line 104
int flush(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

int

in RdKafka at line 106
metadata($all_topics, $only_topic = false, $timeout_ms = 0)

No description

Parameters

$all_topics
$only_topic
$timeout_ms

in RdKafka at line 108
setLogger($logger)

No description

Parameters

$logger

in RdKafka at line 110
outqLen()

No description

in RdKafka at line 112
pausePartitions(array $topic_partitions)

No description

Parameters

array $topic_partitions

in RdKafka at line 116
resumePartitions(array $topic_partitions)

No description

Parameters

array $topic_partitions

in RdKafka at line 120
oauthbearerSetToken(string $token_value, int|float|string $lifetime_ms, string $principal_name, array $extensions = [])

No description

Parameters

string $token_value
int|float|string $lifetime_ms
string $principal_name
array $extensions

in RdKafka at line 124
oauthbearerSetTokenFailure(string $error)

No description

Parameters

string $error

at line 10
__construct(null|Conf $conf = null)

No description

Parameters

null|Conf $conf

at line 25
void initTransactions(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

void

at line 30
void beginTransaction()

No description

Return Value

void

at line 37
void commitTransaction(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

void

at line 44
void abortTransaction(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

void