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 <[email protected]> AuthorDate: Wed Jun 30 15:20:57 2021 +0200 MINIFICPP-1598 Add delay in test for kafka consumer synchronization Signed-off-by: Ferenc Gerlits <[email protected]> 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}")
