Actualiza spring boot y kafka

	<parent>

		<groupId>org.springframework.boot</groupId>

   		<artifactId>spring-boot-starter-parent</artifactId>

    	<version>2.0.3.RELEASE</version>

    	<version>2.1.0.RELEASE</version>

		<relativePath/>

	</parent>

		<redmic.test-utils.version>0.6.0</redmic.test-utils.version>

		<!-- OTHERS -->

		<kafka.version>1.1.0</kafka.version>

		<kafka.version>2.0.0</kafka.version>

		<commons-io.version>2.6</commons-io.version>

		<powermock.version>1.7.3</powermock.version>

import org.springframework.beans.factory.annotation.Value;

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.kafka.annotation.KafkaListener;

import org.springframework.kafka.test.rule.KafkaEmbedded;

import org.springframework.kafka.test.rule.EmbeddedKafkaRule;

import org.springframework.test.annotation.DirtiesContext;

import org.springframework.test.annotation.DirtiesContext.ClassMode;

import org.springframework.test.context.ActiveProfiles;

	private String directoryPath;

	@ClassRule

	public static KafkaEmbedded embeddedKafka = new KafkaEmbedded(1);

	public static EmbeddedKafkaRule embeddedKafka = new EmbeddedKafkaRule(1);

	protected BlockingQueue<Object> blockingQueue;

	@PostConstruct

	public void AISServiceTestPostConstruct() throws Exception {

		createSchemaRegistryRestApp(embeddedKafka.getZookeeperConnectionString(), embeddedKafka.getBrokersAsString());

		createSchemaRegistryRestApp(embeddedKafka.getEmbeddedKafka().getZookeeperConnectionString(),

				embeddedKafka.getEmbeddedKafka().getBrokersAsString());

	}

	@Before