feat(consumer): add a way to stop consumer

Author: simPod

src/Clients/Consumer/KafkaConsumer.php

@@ -146,6 +146,11 @@ public function shutdown(): void
     {
         $this->logger->debug('Shutting down');
 
+        $this->stop();
+    }
+
+    public function stop(): void
+    {
         $this->shouldRun = false;
     }
 
@@ -160,6 +165,7 @@ private function doStart(
         callable|null $onPartitionEof = null,
         callable|null $onTimedOut = null,
     ): void {
+        $this->shouldRun = true;
         $this->registerSignals($this->shouldRun);
 
         while ($this->shouldRun) {