fix callback (#48)

nick-zh · web-flow · commit 993e9b9e9704 · 2020-12-30T10:03:09.000+01:00
diff --git a/src/Consumer/KafkaConsumerBuilder.php b/src/Consumer/KafkaConsumerBuilder.php
@@ -358,7 +358,7 @@ private function registerCallbacks(KafkaConfiguration $conf): void
         }
 
         if (null !== $this->offsetCommitCallback) {
-            $conf->setOffsetCommitCb($this->rebalanceCallback);
+            $conf->setOffsetCommitCb($this->offsetCommitCallback);
         }
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -358,7 +358,7 @@ private function registerCallbacks(KafkaConfiguration $conf): void`
`358`	`358`	`}`
`359`	`359`
`360`	`360`	`if (null !== $this->offsetCommitCallback) {`
`361`		`- $conf->setOffsetCommitCb($this->rebalanceCallback);`
	`361`	`+ $conf->setOffsetCommitCb($this->offsetCommitCallback);`
`362`	`362`	`}`
`363`	`363`	`}`
`364`	`364`	`}`