Embedded Kafka Server based on Kafka-junit. Works with spring dependency injection

KafkaEmbedded.java

import com.salesforce.kafka.test.AbstractKafkaTestResource;
import com.salesforce.kafka.test.KafkaCluster;
import com.salesforce.kafka.test.KafkaTestCluster;
import com.salesforce.kafka.test.junit4.SharedKafkaTestResource;
import org.junit.Ignore;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.context.annotation.Profile;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.util.Properties;

/**
 * Embedded Kafka Service suitable for dependency injection in spring
 */
@Service
@Profile("IT")
@Ignore
class KafkaEmbedded extends AbstractKafkaTestResource<KafkaEmbedded> {

    private static final Logger logger = LoggerFactory.getLogger(SharedKafkaTestResource.class);

    public KafkaEmbedded() {
    }

    public KafkaEmbedded(Properties brokerProperties) {
        super(brokerProperties);
    }

    @PostConstruct
    public void start() throws Exception {
        logger.info("Starting kafka test server");
        if (this.getKafkaCluster() != null) {
            throw new IllegalStateException("Unknown State!  Kafka Test Server already exists!");
        } else {
            this.setKafkaCluster(new KafkaTestCluster(this.getNumberOfBrokers(), this.getBrokerProperties()));
            this.getKafkaCluster().start();
        }
    }

    @PreDestroy
    public void shutdown() {
        logger.info("Shutting down kafka test server");
        if (this.getKafkaCluster() != null) {
            try {
                this.getKafkaCluster().close();
            } catch (Exception var2) {
                throw new RuntimeException(var2);
            }

            this.setKafkaCluster((KafkaCluster)null);
        }
    }

}