diff --git a/tests/rptest/tests/simple_e2e_test.py b/tests/rptest/tests/simple_e2e_test.py index 7bdeaf08060f..cd3f87f962a5 100644 --- a/tests/rptest/tests/simple_e2e_test.py +++ b/tests/rptest/tests/simple_e2e_test.py @@ -67,4 +67,5 @@ def test_consumer_interruption(self): error = e assert error is not None - assert "Consumed from an unexpected" in str(error) + assert "Consumed from an unexpected" in str( + error) or "is behind the current committed offset" in str(error)