mostafa / xk6-kafka / 12161485544

72%

push

github

Flag to return messages received so far when maxWait is reached (#313)

* Flag to return messages received so far when maxWait is reached.

The current behavior, to panic on deadline is problematic, since
there are a number of scenarios where you simply do not know how
many messages there are to consume or when they are produced. For
example, a load test may produce messages in bursts with jitter
for a burn-in test, to try to provoke i data races in the test
subject.

This commit introduces a flag ExpectTimeout which will return message
received so far.

The commit also adds a test to verify that we panic if Close() is
called while we are consuming. Given the nature of the problem
xk6-kafka is trying to solve, this sounds like an errar condition.

* Include expectTimeout in docs.

5 of 5 new or added lines in 1 file covered. (100.0%)

1543 of 2043 relevant lines covered (75.53%)

14.45 hits per line