refactor: Moved common test-code into helper-class `KafkaTestUtils`