$eofwas for... :D
group.id. Only one consumer from the same group is allowed to listen to a particular topic partition.
$conf = new RdKafka\Conf();
$rk = new RdKafka\Consumer($conf);
$queue = $rk->newQueue();
$topicConf = new RdKafka\TopicConf();
$Topic1 = $rk->newTopic("test", $topicConf);
$Topic1->consumeQueueStart(0, RD_KAFKA_OFFSET_STORED, $queue);
$Topic1->consumeQueueStart(1, RD_KAFKA_OFFSET_STORED, $queue);
heya, yeah as you figured out this is possible with https://arnaud.le-blanc.net/php-rdkafka-doc/phpdoc/rdkafka-kafkaconsumer.querywatermakoffsets.html to get the topics offsets and since you have a consumer (high or low, possible with both) you also know where you are with your offsets.
the readme in github and the doc should help how to create a consumer :)
Okay I got it, I have caught min & max for each of my topics with queryWatermarkOffsets. But you told me "you also know where you are with your offsets", what about when offsets are stored server side, for a specific consumer group ?