SimpleKafkaClient

abstract class SimpleKafkaClient (View source)

Methods

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

No description

int
getOutQLen()

No description

int
poll(int $timeoutMs)

No description

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

No description

array
offsetsForTimes(array $topicPartitions, int $timeoutMs)

No description

void
setOAuthBearerTokenFailure(string $errorString)

No description

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

No description

Details

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

at line 23
int getOutQLen()

No description

Return Value

int

at line 29
int poll(int $timeoutMs)

No description

Parameters

int $timeoutMs

Return Value

int

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

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

No description

Parameters

array $topicPartitions
int $timeoutMs

Return Value

array

Exceptions

Exception

at line 52
void setOAuthBearerTokenFailure(string $errorString)

No description

Parameters

string $errorString

Return Value

void

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