diff --git a/pkg/rdkafka/RdKafkaConsumer.php b/pkg/rdkafka/RdKafkaConsumer.php index 6ec89aaf5..3aa568edb 100644 --- a/pkg/rdkafka/RdKafkaConsumer.php +++ b/pkg/rdkafka/RdKafkaConsumer.php @@ -75,6 +75,9 @@ public function setOffset(int $offset = null): void $this->offset = $offset; } + /** + * @return RdKafkaTopic + */ public function getQueue(): Queue { return $this->topic;