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

KafkaConsumer

class KafkaConsumer (View source)

Methods

__construct(Conf $conf)

No description

void
assign(TopicPartition[] $topic_partitions = null)

No description

void
commit(null|Message|TopicPartition[] $message_or_offsets = null)

No description

void
commitAsync(null|Message|TopicPartition[] $message_or_offsets = null)

No description

Message
consume(int $timeout_ms)

No description

TopicPartition[]
getAssignment()

No description

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

No description

array
getSubscription()

No description

void
subscribe(array $topics)

No description

void
unsubscribe()

No description

array
getCommittedOffsets(array $topic_partitions, int $timeout_ms)

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

getOffsetPositions(TopicPartition[] $topic_partitions)

No description

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

No description

void
close()

No description

Details

at line 10
__construct(Conf $conf)

No description

Parameters

Conf $conf

at line 18
void assign(TopicPartition[] $topic_partitions = null)

No description

Parameters

TopicPartition[] $topic_partitions

Return Value

void

Exceptions

Exception

at line 26
void commit(null|Message|TopicPartition[] $message_or_offsets = null)

No description

Parameters

null|Message|TopicPartition[] $message_or_offsets

Return Value

void

Exceptions

Exception

at line 34
void commitAsync(null|Message|TopicPartition[] $message_or_offsets = null)

No description

Parameters

null|Message|TopicPartition[] $message_or_offsets

Return Value

void

Exceptions

Exception

at line 43
Message consume(int $timeout_ms)

No description

Parameters

int $timeout_ms

Return Value

Message

Exceptions

Exception
InvalidArgumentException

at line 49
TopicPartition[] getAssignment()

No description

Return Value

TopicPartition[]

Exceptions

Exception

at line 59
Metadata getMetadata(bool $all_topics, null|KafkaConsumerTopic $only_topic = null, int $timeout_ms)

No description

Parameters

bool $all_topics
null|KafkaConsumerTopic $only_topic
int $timeout_ms

Return Value

Metadata

Exceptions

Exception

at line 64
array getSubscription()

No description

Return Value

array

at line 72
void subscribe(array $topics)

No description

Parameters

array $topics

Return Value

void

Exceptions

Exception

at line 78
void unsubscribe()

No description

Return Value

void

Exceptions

Exception

at line 86
array getCommittedOffsets(array $topic_partitions, int $timeout_ms)

No description

Parameters

array $topic_partitions
int $timeout_ms

Return Value

array

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

No description

Parameters

TopicPartition[] $topic_partitions
int $timeout_ms

Return Value

TopicPartition[]

at line 105
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 110
getOffsetPositions(TopicPartition[] $topic_partitions)

No description

Parameters

TopicPartition[] $topic_partitions

at line 118
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 123
void close()

No description

Return Value

void