Class KafkaConsumerTopic

Class \RdKafka\KafkaConsumerTopic

• extends \RdKafka\Topic

Methods

__construct()

public __construct ( 
    \RdKafka\KafkaConsumer $consumer, 
    string $name, 
    ?\RdKafka\TopicConf $conf = null
 ): 

Parameters

consumer \RdKafka\KafkaConsumer

name string

conf ?\RdKafka\TopicConf

offsetStore()

public offsetStore ( 
    int $partition, 
    int $offset
 ): void

Parameters

partition int

offset int

Test Coverage 💛

• 💛 Lines: 90% (9 / 10)
• ❤️ Methods: 50% (1 / 2)