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