Skip to content
Snippets Groups Projects
Commit 808a4efc authored by David Douard's avatar David Douard
Browse files

Fix flakyness in test_client_with_deserializer

since there is no guarantee the "expected" (considered invalid) revision will
be consumed first, the outcome of this test was flaky. So use the client
with 'stop_on_eof' instead of 'stop_after_objects'.
parent 79d28b51
No related branches found
No related tags found
No related merge requests found
......@@ -363,7 +363,7 @@ def test_client_with_deserializer(
brokers=[kafka_server],
group_id=kafka_consumer_group,
prefix=kafka_prefix,
stop_after_objects=1,
stop_on_eof=True,
value_deserializer=custom_deserializer,
)
worker_fn = MagicMock()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment