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

ConsumerTopic

class ConsumerTopic extends Topic (View source)

Methods

string
getName()

No description

from  Topic
Message|null
consume(int $partition, int $timeout_ms)

No description

void
consumeQueueStart(int $partition, int $offset, Queue $queue)

No description

void
consumeStart(int $partition, int $offset)

No description

void
consumeStop(int $partition)

No description

void
offsetStore(int $partition, int $offset)

No description

consumeCallback($partition, $timeout_ms, $callback)

No description

consumeBatch($partition, $timeout_ms, $batch_size)

No description

Details

in Topic at line 10
string getName()

No description

Return Value

string

at line 15
Message|null consume(int $partition, int $timeout_ms)

No description

Parameters

int $partition
int $timeout_ms

Return Value

Message|null

at line 24
void consumeQueueStart(int $partition, int $offset, Queue $queue)

No description

Parameters

int $partition
int $offset
Queue $queue

Return Value

void

at line 32
void consumeStart(int $partition, int $offset)

No description

Parameters

int $partition
int $offset

Return Value

void

at line 39
void consumeStop(int $partition)

No description

Parameters

int $partition

Return Value

void

at line 47
void offsetStore(int $partition, int $offset)

No description

Parameters

int $partition
int $offset

Return Value

void

at line 49
consumeCallback($partition, $timeout_ms, $callback)

No description

Parameters

$partition
$timeout_ms
$callback

at line 51
consumeBatch($partition, $timeout_ms, $batch_size)

No description

Parameters

$partition
$timeout_ms
$batch_size