diff --git a/src/Consumer/Consumer.php b/src/Consumer/Consumer.php index 5f0cb9f..39d6555 100644 --- a/src/Consumer/Consumer.php +++ b/src/Consumer/Consumer.php @@ -195,6 +195,6 @@ public function setIterations(int $iterations): self private function shouldCreateConsumer(bool $ifNotExists): bool { return ($this->configuration->isEphemeral() && $this->configuration->getName() === null) - || !$this->exists(); + || !$this->exists() || !$ifNotExists; } }