Kafka cluster test infrasturcture is using Kafka internal API which is brittle and prone to issues upon Kafka upgrades. It is not used in that many tests so it could be rpelaced with the one based on testcontainers. Such library is already provided by Strimzi project.