tests: restart producer swarm if needed

Sometimes it may happen that producer swarm is stopped after topic is
recreated leading to a test failure. Added check restarting the producer
if necessary

Signed-off-by: Michal Maslanka <michal@redpanda.com>

tests/rptest/tests/topic_creation_test.py

@@ -94,6 +94,9 @@ def test_topic_recreation_while_producing(self, workload, cleanup_policy):
         rpk = RpkTool(self.redpanda)
 
         def topic_is_healthy():
+            if not swarm.is_alive(swarm.nodes[0]):
+                swarm.stop()
+                swarm.start()
             partitions = rpk.describe_topic(spec.name)
             hw_offsets = [p.high_watermark for p in partitions]
             offsets_present = [hw > 0 for hw in hw_offsets]
@@ -106,7 +109,10 @@ def topic_is_healthy():
             self.client().delete_topic(spec.name)
             spec.replication_factor = rf
             self.client().create_topic(spec)
-            wait_until(topic_is_healthy, 30, 2)
+            wait_until(topic_is_healthy,
+                       30,
+                       2,
+                       err_msg=f"Topic {spec.name} health")
             sleep(5)
 
         swarm.stop()