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

Producer

class Producer extends SimpleKafkaClient (View source)

Methods

Metadata
getMetadata(bool $allTopics, int $timeoutMs, Topic $topic)

No description

from  SimpleKafkaClient
int
getOutQLen()

No description

from  SimpleKafkaClient
int
poll(int $timeoutMs)

No description

from  SimpleKafkaClient
void
queryWatermarkOffsets(string $topic, int $partition, int $low, int $high, int $timeoutMs)

No description

from  SimpleKafkaClient
array
offsetsForTimes(array $topicPartitions, int $timeoutMs)

No description

from  SimpleKafkaClient
void
setOAuthBearerTokenFailure(string $errorString)

No description

from  SimpleKafkaClient
void
setOAuthBearerToken(string $token, int $lifetimeMs, string $principalName, array|null $extensions = null)

No description

from  SimpleKafkaClient
__construct(Configuration $configuration)

Producer constructor.

void
initTransactions(int $timeoutMs)

No description

void
beginTransaction()

No description

void
commitTransaction(int $timeoutMs)

No description

void
abortTransaction(int $timeoutMs)

No description

int
flush(int $timeoutMs)

No description

int
purge(int $purgeFlags)

No description

ProducerTopic
getTopicHandle(string $topic)

No description

Details

in SimpleKafkaClient at line 18
Metadata getMetadata(bool $allTopics, int $timeoutMs, Topic $topic)

No description

Parameters

bool $allTopics
int $timeoutMs
Topic $topic

Return Value

Metadata

Exceptions

Exception

in SimpleKafkaClient at line 23
int getOutQLen()

No description

Return Value

int

in SimpleKafkaClient at line 29
int poll(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

int

in SimpleKafkaClient at line 39
void queryWatermarkOffsets(string $topic, int $partition, int $low, int $high, int $timeoutMs)

No description

Parameters

string $topic
int $partition
int $low

is passed as reference, contains result after call
int $high

is passed as reference, contains result after call
int $timeoutMs

Return Value

void

Exceptions

Exception

in SimpleKafkaClient at line 47
array offsetsForTimes(array $topicPartitions, int $timeoutMs)

No description

Parameters

array $topicPartitions
int $timeoutMs

Return Value

array

Exceptions

Exception

in SimpleKafkaClient at line 52
void setOAuthBearerTokenFailure(string $errorString)

No description

Parameters

string $errorString

Return Value

void

in SimpleKafkaClient at line 60
void setOAuthBearerToken(string $token, int $lifetimeMs, string $principalName, array|null $extensions = null)

No description

Parameters

string $token
int $lifetimeMs
string $principalName
array|null $extensions

Return Value

void

at line 15
__construct(Configuration $configuration)

Producer constructor.

Parameters

Configuration $configuration

Exceptions

Exception

at line 21
void initTransactions(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

void

Exceptions

Exception

at line 27
void beginTransaction()

No description

Return Value

void

Exceptions

Exception

at line 33
void commitTransaction(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

void

Exceptions

Exception

at line 39
void abortTransaction(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

void

Exceptions

Exception

at line 45
int flush(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

int

at line 51
int purge(int $purgeFlags)

No description

Parameters

int $purgeFlags

Return Value

int

at line 57
ProducerTopic getTopicHandle(string $topic)

No description

Parameters

string $topic

Return Value

ProducerTopic