import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.test.context.SpringBootTest;
-@EmbeddedKafka(partitions = 1, brokerProperties = { "listeners=PLAINTEXT://localhost:9092", "port=9092" })
+@EmbeddedKafka(partitions = 1, ports = 9092, topics = {"${topics.distribution.notification}"})
// TODO: mock distribution client requests to /sdc/v1/artifactTypes
// TODO: mock distribution client requests to /sdc/v1/distributionKafkaData
// TODO: mock distribution client requests to /sdc/v1/artifactTypes
// TODO: mock distribution client requests to /sdc/v1/distributionKafkaData