For more details of how this test works, please look into docs/kafka-tests.md