[nifi-minifi-cpp] 03/04: MINIFICPP-1598 Add delay in test for kafka consumer synchronization

[fg...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

fgerlits pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git

commit 4175b33654de400cf565d06777616d6bc1fef269
Author: Gabor Gyimesi <ga...@gmail.com>
AuthorDate: Wed Jun 30 15:20:57 2021 +0200

    MINIFICPP-1598 Add delay in test for kafka consumer synchronization
    
    Signed-off-by: Ferenc Gerlits <fg...@gmail.com>
    
    This closes #1122
---
 docker/test/integration/steps/steps.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/docker/test/integration/steps/steps.py b/docker/test/integration/steps/steps.py
index cb8bce7..0b4f835 100644
--- a/docker/test/integration/steps/steps.py
+++ b/docker/test/integration/steps/steps.py
@@ -444,6 +444,9 @@ def step_impl(context, content, topic_name, semicolon_separated_headers):
 @when("the Kafka consumer is registered in kafka broker \"{cluster_name}\"")
 def step_impl(context, cluster_name):
     context.test.wait_for_kafka_consumer_to_be_registered(cluster_name)
+    # After the consumer is registered there is still some time needed for consumer-broker synchronization
+    # Unfortunately there are no additional log messages that could be checked for this
+    time.sleep(2)
 
 
 @then("a flowfile with the content \"{content}\" is placed in the monitored directory in less than {duration}")