Currently running all the tests from test_storage_kafka/test.py takes a lot of time, on my local machine ~40mins. This is really bad, because flaky test checks and bugfix validation cannot differentiate between individual test cases in a single file, which means they likely to get timed out.