Gábor Gyimesi created MINIFICPP-2794:
----------------------------------------
Summary: ConsumeKafka
Key: MINIFICPP-2794
URL: https://issues.apache.org/jira/browse/MINIFICPP-2794
Project: Apache NiFi MiNiFi C++
Issue Type: Bug
Reporter: Gábor Gyimesi
Fix For: 1.0.0
Attachments: rocky9_aarch64_behavex_output_modular_fips(3).zip,
ubuntu_jammy_aarch64_behavex_output_modular_fips(1).zip,
ubuntu_jammy_x86_64_behavex_output_modular_fips(3).zip
"The ConsumeKafka "Maximum Poll Records" property sets a limit on the messages
processed in a single batch" docker test transiently fails in verify package
runs.
{code:java}
Then after a wait of 15 seconds, at least 12 and at most 24 files are produced
and placed in the "/tmp/output" directory (Step failed)
Traceback (most recent call last):
File "/home/runner/work
ifi-minifi-cpp
ifi-minifi-cpp/build/behave_venv/lib/python3.12/site-packages/behave/model.py",
line 1991, in run
match.run(runner.context)
File "/home/runner/work
ifi-minifi-cpp
ifi-minifi-cpp/build/behave_venv/lib/python3.12/site-packages/behave/matchers.py",
line 105, in run
self.func(context, *args, **kwargs)
File "/home/runner/work
ifi-minifi-cpp
ifi-minifi-cpp/behave_framework/src/minifi_test_framework/steps/checking_steps.py",
line 230, in verify_file_count_bounds_in_directory
assert check_condition_after_wait(condition=lambda:
context.containers[DEFAULT_MINIFI_CONTAINER_NAME].get_number_of_files(directory)
>= lower_bound
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
AssertionError{code}
See info in attached logs.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
