From 1aca4f57819244e551a8e896cb2a70338196e5ae Mon Sep 17 00:00:00 2001
From: ggaborg <ggaborg@yahoo.com>
Date: Mon, 14 Nov 2022 11:11:45 +0200
Subject: [PATCH] DBZ-4720 wait for kafka consumer

---
 .../src/test/java/io/debezium/server/kafka/KafkaIT.java       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/debezium-server/debezium-server-kafka/src/test/java/io/debezium/server/kafka/KafkaIT.java b/debezium-server/debezium-server-kafka/src/test/java/io/debezium/server/kafka/KafkaIT.java
index 4058baa06..724c28dfa 100644
--- a/debezium-server/debezium-server-kafka/src/test/java/io/debezium/server/kafka/KafkaIT.java
+++ b/debezium-server/debezium-server-kafka/src/test/java/io/debezium/server/kafka/KafkaIT.java
@@ -79,7 +79,9 @@ static void stop() throws Exception {
 
     @Test
     public void testKafka() throws Exception {
-
+        Awaitility.await().atMost(Duration.ofSeconds(KafkaTestConfigSource.waitForSeconds())).until(() -> {
+            return consumer != null;
+        });
         consumer.subscribe(Arrays.asList(TOPIC_NAME));
 
         final List<ConsumerRecord<String, String>> actual = new ArrayList<>();