Añade configuración para usar schemaRegistry local

spring.kafka.bootstrap-servers=${spring.embedded.kafka.brokers}

spring.kafka.properties.schema.registry.url=http://redmic.net:18081

spring.kafka.properties.schema.registry.url=http://localhost:${schema.registry.port}

config.fixedDelay=100

app.scheduling.enable=false

import java.util.concurrent.BlockingQueue;

import java.util.concurrent.LinkedBlockingDeque;

import javax.annotation.PostConstruct;

import org.apache.commons.io.FileUtils;

import org.junit.Before;

import org.junit.ClassRule;

import org.springframework.test.annotation.DirtiesContext;

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

import org.springframework.test.context.ActiveProfiles;

import org.springframework.test.context.TestPropertySource;

import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import es.redmic.ais.AISApplication;

import es.redmic.ais.service.AISService;

import es.redmic.brokerlib.avro.geodata.tracking.vessels.AISTrackingDTO;

import es.redmic.exception.custom.ResourceNotFoundException;

import es.redmic.testutils.kafka.KafkaBaseIntegrationTest;

@RunWith(SpringJUnit4ClassRunner.class)

@SpringBootTest(classes = { AISApplication.class })

@ActiveProfiles("test")

@TestPropertySource(properties = { "schema.registry.port=18081" })

@DirtiesContext(classMode = ClassMode.AFTER_EACH_TEST_METHOD)

public class AISServiceTest {

public class AISServiceTest extends KafkaBaseIntegrationTest {

	@Autowired

	AISService aisService;

	protected BlockingQueue<Object> blockingQueue;

	@PostConstruct

	public void CreateVesselFromTrackingTestPostConstruct() throws Exception {

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

	}

	@Before

	public void setup() {