Merge pull request #1184 from DigitVE/adding-new-getter-for-offset-in-rdkafka

makasim · web-flow · commit 770bebae50d1 · 2021-09-22T10:07:58.000+03:00
Added getter for offset field in RdKafkaConsumer class
diff --git a/RdKafkaConsumer.php b/RdKafkaConsumer.php
@@ -66,6 +66,11 @@ public function setCommitAsync(bool $async): void
         $this->commitAsync = $async;
     }
 
+    public function getOffset(): ?int
+    {
+        return $this->offset;
+    }
+
     public function setOffset(int $offset = null): void
     {
         if ($this->subscribed) {

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,11 @@ public function setCommitAsync(bool $async): void`
`66`	`66`	`$this->commitAsync = $async;`
`67`	`67`	`}`
`68`	`68`
	`69`	`+ public function getOffset(): ?int`
	`70`	`+ {`
	`71`	`+ return $this->offset;`
	`72`	`+ }`
	`73`	`+`
`69`	`74`	`public function setOffset(int $offset = null): void`
`70`	`75`	`{`
`71`	`76`	`if ($this->subscribed) {`