topic.stub.php

<?php

/**
 * @generate-class-entries
 * @generate-function-entries
 * @generate-legacy-arginfo
 */

namespace RdKafka;

abstract class Topic
{
    /** @tentative-return-type */
    public function getName(): string {}
}

class ConsumerTopic extends Topic
{
    /** @implementation-alias RdKafka::__construct */
    private function __construct() {}

    /** @tentative-return-type */
    public function consumeQueueStart(int $partition, int $offset, Queue $queue): void {}

    /** @tentative-return-type */
    public function consumeCallback(int $partition, int $timeout_ms, callable $callback): int {}

    /** @tentative-return-type */
    public function consumeStart(int $partition, int $offset): void {}

    /** @tentative-return-type */
    public function consumeStop(int $partition): void {}

    /** @tentative-return-type */
    public function consume(int $partition, int $timeout_ms): ?Message {}

    /** @tentative-return-type */
    public function consumeBatch(int $partition, int $timeout_ms, int $batch_size): array {}

    /** @tentative-return-type */
    public function offsetStore(int $partition, int $offset): void {}
}

class KafkaConsumerTopic extends Topic
{
    /** @implementation-alias RdKafka::__construct */
    private function __construct() {}

    /**
     * @implementation-alias RdKafka\ConsumerTopic::offsetStore
     * @tentative-return-type
     */
    public function offsetStore(int $partition, int $offset): void {}
}

class ProducerTopic extends Topic
{
    /** @implementation-alias RdKafka::__construct */
    private function __construct() {}

    /** @tentative-return-type */
    public function produce(int $partition, int $msgflags, ?string $payload = null, ?string $key = null, ?string $msg_opaque = null): void {}

    /** @tentative-return-type */
    public function producev(int $partition, int $msgflags, ?string $payload = null, ?string $key = null, ?array $headers = null, ?int $timestamp_ms = null, ?string $msg_opaque = null): void {}
}