#93909 create topic before subscribing

Author: Ivan Koryukov

src/HighLevelConsumer.php

@@ -130,8 +130,16 @@ protected function shouldBeStopped(int|float $startTime, int $eventsProcessed, C
 
     protected function subscribe(string $topicName): void
     {
-        $this->consumer->newTopic($topicName);
-        sleep(1);
+        $attempts = 0;
+        do {
+            $topicExists = (bool)$this->getPartitions($topicName);
+            if (!$topicExists) {
+                $this->consumer->newTopic($topicName);
+                sleep(1);
+            }
+            $attempts++;
+        } while (!$topicExists && $attempts < 10);
+
         $this->consumer->subscribe([$topicName]);
     }