From edca1393559befc075e962e1d3f0d5aa06acd719 Mon Sep 17 00:00:00 2001
From: ggaborg <ggaborg@yahoo.com>
Date: Mon, 14 Nov 2022 10:48:37 +0200
Subject: [PATCH] DBZ-4720 wait for pulsarClient

---
 .../src/test/java/io/debezium/server/pulsar/PulsarIT.java      | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/debezium-server/debezium-server-pulsar/src/test/java/io/debezium/server/pulsar/PulsarIT.java b/debezium-server/debezium-server-pulsar/src/test/java/io/debezium/server/pulsar/PulsarIT.java
index 06c1c3247..61e746293 100644
--- a/debezium-server/debezium-server-pulsar/src/test/java/io/debezium/server/pulsar/PulsarIT.java
+++ b/debezium-server/debezium-server-pulsar/src/test/java/io/debezium/server/pulsar/PulsarIT.java
@@ -84,6 +84,9 @@ void connectorCompleted(@Observes ConnectorCompletedEvent event) throws Exceptio
 
     @Test
     public void testPulsar() throws Exception {
+        Awaitility.await().atMost(Duration.ofSeconds(PulsarTestConfigSource.waitForSeconds())).until(() -> {
+            return pulsarClient != null;
+        });
         final Consumer<String> consumer = pulsarClient.newConsumer(Schema.STRING)
                 .topic(TOPIC_NAME)
                 .subscriptionName("test-" + UUID.randomUUID())