rptest: write caching tests with failure injection #17671
Conversation
|
This still a draft? |
|
@bharathv need to merge the other PR first otherwise this fails |
nvartolomei
force-pushed
the
nv/low-level-write-caching-test
branch
3 times, most recently
from
b705493
to
434c2f8
Compare
nvartolomei
force-pushed
the
nv/low-level-write-caching-test
branch
from
434c2f8
to
75ffe7b
Compare
| total_produced += num_msg_per_round | ||
|
|
||
| @cluster(num_nodes=4) | ||
| def test_crash_all(self): |
There was a problem hiding this comment.
think this is same as the test in the other PR?
There was a problem hiding this comment.
It is pretty much the same but this one doesn't have a dependency of the correctly implemented consumer. This is much easier to debug and work with.
I'd prefer to keep both.
| valid_reads), "unexpected number of consumed messages" | ||
|
|
||
| @cluster(num_nodes=4) | ||
| def test_leader_epoch(self): |
There was a problem hiding this comment.
I believe you already added a similar test in unit tests,, wondering if we need this (in the spirit of reducing test runtime).. I don't mind keeping it, just asking.
There was a problem hiding this comment.
They are similar in the expectations but the behavior is different enough to have a separate test. This one asserts the behavior during data-loss scenario thus exercising more than just kafka layer.
Depends on #17674
Backports Required
Release Notes